Skip to content

Commit

Permalink
Remove warning from optional schema (#863)
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 authored Aug 30, 2024
1 parent 0f6cae6 commit 71fc8b7
Showing 1 changed file with 2 additions and 9 deletions.
11 changes: 2 additions & 9 deletions lib/cdc/util/optional_schema.go
Original file line number Diff line number Diff line change
@@ -1,28 +1,21 @@
package util

import (
"log/slog"

"github.com/artie-labs/transfer/lib/debezium"
"github.com/artie-labs/transfer/lib/typing"
)

func (s *SchemaEventPayload) GetOptionalSchema() map[string]typing.KindDetails {
fieldsObject := s.Schema.GetSchemaFromLabel(debezium.After)
if fieldsObject == nil {
// AFTER schema does not exist.
return nil
}

schema := make(map[string]typing.KindDetails)
for _, field := range fieldsObject.Fields {
kd := field.ToKindDetails()
if kd == typing.Invalid {
slog.Warn("Skipping field from optional schema b/c we cannot determine the data type", slog.String("field", field.FieldName))
continue
if kd := field.ToKindDetails(); kd != typing.Invalid {
schema[field.FieldName] = kd
}

schema[field.FieldName] = kd
}

return schema
Expand Down

0 comments on commit 71fc8b7

Please sign in to comment.