Skip to content

Commit eb8b7c4

Browse files
authored
fix: Truncate timestamp to millisecond in dest testing (#806)
This will work for now but we will improve it later when we work more on our testing suite for destinations
1 parent 506dab1 commit eb8b7c4

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

testdata/testdata.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -186,13 +186,13 @@ func GenTestData(mem memory.Allocator, sc *arrow.Schema, opts GenTestDataOptions
186186
bldr.Field(i).(*array.ListBuilder).ValueBuilder().(*array.Int64Builder).Append(2)
187187
} else if arrow.TypeEqual(c.Type, arrow.FixedWidthTypes.Timestamp_us) {
188188
if c.Name == schema.CqSyncTimeColumn.Name {
189-
bldr.Field(i).(*array.TimestampBuilder).Append(arrow.Timestamp(opts.SyncTime.UTC().UnixMicro()))
189+
bldr.Field(i).(*array.TimestampBuilder).Append(arrow.Timestamp(opts.SyncTime.UTC().Truncate(time.Millisecond).UnixMicro()))
190190
} else {
191191
t := time.Now()
192192
if !opts.StableTime.IsZero() {
193193
t = opts.StableTime
194194
}
195-
bldr.Field(i).(*array.TimestampBuilder).Append(arrow.Timestamp(t.UTC().UnixMicro()))
195+
bldr.Field(i).(*array.TimestampBuilder).Append(arrow.Timestamp(t.UTC().Truncate(time.Millisecond).UnixMicro()))
196196
}
197197
} else if arrow.TypeEqual(c.Type, types.ExtensionTypes.JSON) {
198198
bldr.Field(i).(*types.JSONBuilder).Append(map[string]interface{}{"test": "test"})

0 commit comments

Comments
 (0)