From 9b012edc1fbbc8685e06efd3dd902c7eb0d7cfc7 Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Thu, 31 Oct 2024 21:57:28 -0700 Subject: [PATCH] Upgrade + Fix Tests. --- go.mod | 2 +- go.sum | 4 ++-- lib/debezium/converters/time_test.go | 8 ++++---- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/go.mod b/go.mod index 90e86e04..aad0088d 100644 --- a/go.mod +++ b/go.mod @@ -4,7 +4,7 @@ go 1.23.0 require ( github.com/DataDog/datadog-go/v5 v5.5.0 - github.com/artie-labs/transfer v1.27.22 + github.com/artie-labs/transfer v1.27.24 github.com/aws/aws-sdk-go-v2 v1.30.3 github.com/aws/aws-sdk-go-v2/config v1.27.27 github.com/aws/aws-sdk-go-v2/credentials v1.17.27 diff --git a/go.sum b/go.sum index dc8be6b9..6bdf9669 100644 --- a/go.sum +++ b/go.sum @@ -98,8 +98,8 @@ github.com/apache/thrift v0.0.0-20181112125854-24918abba929/go.mod h1:cp2SuWMxlE github.com/apache/thrift v0.14.2/go.mod h1:cp2SuWMxlEZw2r+iP2GNCdIi4C1qmUzdZFSVb+bacwQ= github.com/apache/thrift v0.17.0 h1:cMd2aj52n+8VoAtvSvLn4kDC3aZ6IAkBuqWQ2IDu7wo= github.com/apache/thrift v0.17.0/go.mod h1:OLxhMRJxomX+1I/KUw03qoV3mMz16BwaKI+d4fPBx7Q= -github.com/artie-labs/transfer v1.27.22 h1:Frd6mp/jKOF6NIcspNtS6unuoL5ISKKCmhBNMIlEHnU= -github.com/artie-labs/transfer v1.27.22/go.mod h1:Lbrj8nz/cCq5BycDR++l3K+kc2GUbEnGRyrVDyA8MfM= +github.com/artie-labs/transfer v1.27.24 h1:GjWnm3P1FZ8WImCyrQKx0GRGBI0tBdce0p/eoodluLM= +github.com/artie-labs/transfer v1.27.24/go.mod h1:Lbrj8nz/cCq5BycDR++l3K+kc2GUbEnGRyrVDyA8MfM= github.com/aws/aws-sdk-go v1.30.19/go.mod h1:5zCpMtNQVjRREroY7sYe8lOMRSxkhG6MZveU8YkpAk0= github.com/aws/aws-sdk-go-v2 v1.16.12/go.mod h1:C+Ym0ag2LIghJbXhfXZ0YEEp49rBWowxKzJLUoob0ts= github.com/aws/aws-sdk-go-v2 v1.30.3 h1:jUeBtG0Ih+ZIFH0F4UkmL9w3cSpaMv9tYYDbzILP8dY= diff --git a/lib/debezium/converters/time_test.go b/lib/debezium/converters/time_test.go index 1c5e59d3..9cd12438 100644 --- a/lib/debezium/converters/time_test.go +++ b/lib/debezium/converters/time_test.go @@ -301,7 +301,7 @@ func TestZonedTimestampConverter_Convert(t *testing.T) { // Check Transfer to ensure no precision loss ts, err := converters.ZonedTimestamp{}.Convert(value) assert.NoError(t, err) - assert.Equal(t, _ts, ts.(*ext.ExtendedTime).GetTime()) + assert.Equal(t, _ts, ts.(time.Time)) } { // time.Time (ms) @@ -313,7 +313,7 @@ func TestZonedTimestampConverter_Convert(t *testing.T) { // Check Transfer to ensure no precision loss ts, err := converters.ZonedTimestamp{}.Convert(value) assert.NoError(t, err) - assert.Equal(t, _ts, ts.(*ext.ExtendedTime).GetTime()) + assert.Equal(t, _ts, ts.(time.Time)) } { // time.Time (microseconds) @@ -325,7 +325,7 @@ func TestZonedTimestampConverter_Convert(t *testing.T) { // Check Transfer to ensure no precision loss ts, err := converters.ZonedTimestamp{}.Convert(value) assert.NoError(t, err) - assert.Equal(t, _ts, ts.(*ext.ExtendedTime).GetTime()) + assert.Equal(t, _ts, ts.(time.Time)) } { // Different timezone @@ -337,7 +337,7 @@ func TestZonedTimestampConverter_Convert(t *testing.T) { // Check Transfer to ensure no precision loss ts, err := converters.ZonedTimestamp{}.Convert(value) assert.NoError(t, err) - assert.Equal(t, _ts.UTC(), ts.(*ext.ExtendedTime).GetTime()) + assert.Equal(t, _ts.UTC(), ts.(time.Time)) } }