Support bit varying.

artie-labs · Oct 5, 2024 · 1b2f7d0 · 1b2f7d0
1 parent 0179450
commit 1b2f7d0
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/lib/debezium/converters/bit_varying.go b/lib/debezium/converters/bit_varying.go
@@ -14,7 +14,7 @@ func NewBitVaryingConverter(optionalCharMaxLength int) BitVaryingConverter {
 	return BitVaryingConverter{optionalCharMaxLength: optionalCharMaxLength}
 }
 
-func (BitVaryingConverter) ToField(name string) Field {
+func (BitVaryingConverter) ToField(name string) debezium.Field {
 	return debezium.Field{
 		FieldName:    name,
 		DebeziumType: debezium.Bits,
@@ -38,5 +38,5 @@ func (b BitVaryingConverter) Convert(value any) (any, error) {
 		}
 	}
 
-	return stringToByteA(stringValue), nil
+	return stringToByteA(stringValue)
 }
diff --git a/lib/postgres/scanner_test.go b/lib/postgres/scanner_test.go
@@ -93,7 +93,7 @@ func TestScanAdapter_ParsePrimaryKeyValueForOverrides(t *testing.T) {
 			name:        "unsupported data type",
 			dataType:    schema.Array,
 			value:       "1234",
-			expectedErr: `DataType(21) for column "col" is not supported for use as a primary key`,
+			expectedErr: `DataType(22) for column "col" is not supported for use as a primary key`,
 		},
 		{
 			name:        "boolean - malformed",