Upgrading deps (#497)

artie-labs · Sep 21, 2024 · e09b5a6 · e09b5a6
1 parent 7501cbe
commit e09b5a6
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 8 deletions.
diff --git 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.9
+	github.com/artie-labs/transfer v1.27.10
 	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
@@ -93,8 +93,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.9 h1:/X8+sJYTtOB6Jf6JZr9fXiDaowpYAUTzg6KWJte9ELU=
-github.com/artie-labs/transfer v1.27.9/go.mod h1:+a/UhlQVRIpdz3muS1yhSvyX42RQL0LHOdovGZfEsDE=
+github.com/artie-labs/transfer v1.27.10 h1:S92HE1xHj6v3dyxEyOLQoUYr2g3ZFCuj54XbagAmfic=
+github.com/artie-labs/transfer v1.27.10/go.mod h1:+a/UhlQVRIpdz3muS1yhSvyX42RQL0LHOdovGZfEsDE=
 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.go b/lib/debezium/converters/time.go
@@ -171,7 +171,7 @@ func (ZonedTimestampConverter) ToField(name string) debezium.Field {
 	return debezium.Field{
 		FieldName:    name,
 		Type:         debezium.String,
-		DebeziumType: debezium.DateTimeWithTimezone,
+		DebeziumType: debezium.ZonedTimestamp,
 	}
 }
 

diff --git a/lib/debezium/converters/time_test.go b/lib/debezium/converters/time_test.go
@@ -292,7 +292,7 @@ func TestZonedTimestampConverter_Convert(t *testing.T) {
 		assert.Equal(t, "2001-02-03T04:05:00Z", value)
 
 		// Check Transfer to ensure no precision loss
-		ts, err := converters.DateTimeWithTimezone{}.Convert(value)
+		ts, err := converters.ZonedTimestamp{}.Convert(value)
 		assert.NoError(t, err)
 		assert.Equal(t, _ts, ts.(*ext.ExtendedTime).GetTime())
 	}
@@ -304,7 +304,7 @@ func TestZonedTimestampConverter_Convert(t *testing.T) {
 		assert.Equal(t, "2001-02-03T04:05:01.0009Z", value)
 
 		// Check Transfer to ensure no precision loss
-		ts, err := converters.DateTimeWithTimezone{}.Convert(value)
+		ts, err := converters.ZonedTimestamp{}.Convert(value)
 		assert.NoError(t, err)
 		assert.Equal(t, _ts, ts.(*ext.ExtendedTime).GetTime())
 	}
@@ -316,7 +316,7 @@ func TestZonedTimestampConverter_Convert(t *testing.T) {
 		assert.Equal(t, "2001-02-03T04:05:01.000909Z", value)
 
 		// Check Transfer to ensure no precision loss
-		ts, err := converters.DateTimeWithTimezone{}.Convert(value)
+		ts, err := converters.ZonedTimestamp{}.Convert(value)
 		assert.NoError(t, err)
 		assert.Equal(t, _ts, ts.(*ext.ExtendedTime).GetTime())
 	}
@@ -328,7 +328,7 @@ func TestZonedTimestampConverter_Convert(t *testing.T) {
 		assert.Equal(t, "2001-02-03T03:05:00Z", value)
 
 		// Check Transfer to ensure no precision loss
-		ts, err := converters.DateTimeWithTimezone{}.Convert(value)
+		ts, err := converters.ZonedTimestamp{}.Convert(value)
 		assert.NoError(t, err)
 		assert.Equal(t, _ts.UTC(), ts.(*ext.ExtendedTime).GetTime())
 	}