From 54d9b05a2ae4fe605506242ad6f2eb71c55c3852 Mon Sep 17 00:00:00 2001 From: Kevin Biju Date: Fri, 13 Dec 2024 16:44:51 +0530 Subject: [PATCH] try and exclude column names with hyphens --- flow/shared/schema_helpers.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/flow/shared/schema_helpers.go b/flow/shared/schema_helpers.go index 7f48d3cbb5..04b6dd8abf 100644 --- a/flow/shared/schema_helpers.go +++ b/flow/shared/schema_helpers.go @@ -4,6 +4,7 @@ import ( "log/slog" "maps" "slices" + "strings" "go.temporal.io/sdk/log" @@ -52,7 +53,7 @@ func BuildProcessedSchemaMapping( columns := make([]*protos.FieldDescription, 0, len(tableSchema.Columns)) pkeyColumns := make([]string, 0, len(tableSchema.PrimaryKeyColumns)) for _, column := range tableSchema.Columns { - if !slices.Contains(mapping.Exclude, column.Name) { + if !slices.Contains(mapping.Exclude, column.Name) && !strings.Contains(column.Name, "-") { columns = append(columns, column) } if slices.Contains(tableSchema.PrimaryKeyColumns, column.Name) &&