Skip to content

Commit c44760f

Browse files
committed
refactor other test
1 parent 107e6b7 commit c44760f

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

plugin/testing_write_delete.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -53,9 +53,10 @@ func (s *WriterTestSuite) testDeleteStaleBasic(ctx context.Context, t *testing.T
5353
r.EqualValuesf(1, TotalRows(records), "unexpected amount of items after delete stale")
5454
r.Emptyf(RecordsDiff(table.ToArrowSchema(), records, []arrow.Record{record1}), "record differs after delete stale")
5555

56+
syncTime = syncTime.Add(time.Second)
5657
bldr.Field(0).(*array.Int64Builder).Append(1)
5758
bldr.Field(1).(*array.StringBuilder).Append(sourceName)
58-
bldr.Field(2).(*array.TimestampBuilder).AppendTime(syncTime.Add(time.Second))
59+
bldr.Field(2).(*array.TimestampBuilder).AppendTime(syncTime)
5960
record2 := bldr.NewRecord()
6061

6162
r.NoErrorf(s.plugin.writeOne(ctx, &message.WriteInsert{Record: record2}), "failed to insert second record")
@@ -70,7 +71,7 @@ func (s *WriterTestSuite) testDeleteStaleBasic(ctx context.Context, t *testing.T
7071
r.NoErrorf(s.plugin.writeOne(ctx, &message.WriteDeleteStale{
7172
TableName: table.Name,
7273
SourceName: sourceName,
73-
SyncTime: syncTime.Add(time.Second),
74+
SyncTime: syncTime,
7475
}), "failed to delete stale records second time")
7576

7677
records, err = s.plugin.readAll(ctx, table)
@@ -117,7 +118,7 @@ func (s *WriterTestSuite) testDeleteStaleAll(ctx context.Context, t *testing.T)
117118
r.EqualValuesf(rowsPerRecord, TotalRows(readRecords), "unexpected amount of items after delete stale")
118119

119120
// https://github.com/golang/go/issues/41087
120-
syncTime = time.Now().UTC().Truncate(time.Microsecond).Add(time.Second)
121+
syncTime = syncTime.Add(time.Second)
121122
nullRecord := tg.Generate(table, schema.GenTestDataOptions{
122123
MaxRows: rowsPerRecord,
123124
TimePrecision: s.genDatOptions.TimePrecision,

0 commit comments

Comments
 (0)