Skip to content

Commit 84891f4

Browse files
committed
fix: test failures
1 parent 50ffd80 commit 84891f4

2 files changed

Lines changed: 7 additions & 7 deletions

File tree

cmd/substreams-sink-sql/from_proto_generate_csv_comprehensive_test.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -571,11 +571,11 @@ func TestCSVRowFormattingRisingWaveTimestamp(t *testing.T) {
571571

572572
blockTime := time.Date(2024, time.January, 15, 10, 30, 0, 987000000, time.FixedZone("UTC-5", -5*3600))
573573
row := map[string]interface{}{
574-
sql.DialectFieldBlockNumber: uint64(12345),
575-
sql.DialectFieldBlockTimestamp: blockTime,
576-
"text_field": "Hello, \"World\"",
577-
"int_field": int64(42),
578-
"bool_field": true,
574+
dialectBlockNumberName(dialect): uint64(12345),
575+
dialectBlockTimestampName(dialect): blockTime,
576+
"text_field": "Hello, \"World\"",
577+
"int_field": int64(42),
578+
"bool_field": true,
579579
}
580580

581581
csvData := gen.formatRowForCSV(row, testTable)

internal/timefmt/risingwave_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,8 +6,8 @@ import (
66
)
77

88
func TestFormatRisingWave(t *testing.T) {
9-
t := time.Date(2025, time.September, 18, 15, 18, 52, 123456789, time.FixedZone("UTC-4", -4*3600))
10-
got := FormatRisingWave(t)
9+
ts := time.Date(2025, time.September, 18, 15, 18, 52, 123456789, time.FixedZone("UTC-4", -4*3600))
10+
got := FormatRisingWave(ts)
1111
want := "2025-09-18 19:18:52.123456+00:00"
1212
if got != want {
1313
t.Fatalf("FormatRisingWave() = %q, want %q", got, want)

0 commit comments

Comments
 (0)