Skip to content

Commit 107e6b7

Browse files
committed
fix: Add time delay in DeleteStaleAll test for destinations
1 parent 2e3c192 commit 107e6b7

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

plugin/testing_write_delete.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -117,7 +117,7 @@ func (s *WriterTestSuite) testDeleteStaleAll(ctx context.Context, t *testing.T)
117117
r.EqualValuesf(rowsPerRecord, TotalRows(readRecords), "unexpected amount of items after delete stale")
118118

119119
// https://github.com/golang/go/issues/41087
120-
syncTime = time.Now().UTC().Truncate(time.Microsecond)
120+
syncTime = time.Now().UTC().Truncate(time.Microsecond).Add(time.Second)
121121
nullRecord := tg.Generate(table, schema.GenTestDataOptions{
122122
MaxRows: rowsPerRecord,
123123
TimePrecision: s.genDatOptions.TimePrecision,
@@ -144,6 +144,7 @@ func (s *WriterTestSuite) testDeleteStaleAll(ctx context.Context, t *testing.T)
144144
readRecords, err = s.plugin.readAll(ctx, table)
145145
r.NoErrorf(err, "failed to read after second delete stale")
146146
sortRecords(table, readRecords, "id")
147+
147148
r.EqualValuesf(rowsPerRecord, TotalRows(readRecords), "unexpected amount of items after second delete stale")
148149
r.Emptyf(RecordsDiff(table.ToArrowSchema(), readRecords, []arrow.Record{nullRecord}), "record differs")
149150
}

0 commit comments

Comments
 (0)