From 0d35904aa6d8c494ee4bf61b309fa914ae7bcf1c Mon Sep 17 00:00:00 2001 From: Amogh Bharadwaj Date: Tue, 12 Mar 2024 21:55:13 +0530 Subject: [PATCH] SF QRep: Fix column casing issues (#1476) --- flow/connectors/snowflake/snowflake.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go index e74a954c38..fb821b5e0e 100644 --- a/flow/connectors/snowflake/snowflake.go +++ b/flow/connectors/snowflake/snowflake.go @@ -905,7 +905,7 @@ func (c *SnowflakeConnector) getTableSchemaForTable(ctx context.Context, tableNa colFields := make([]*protos.FieldDescription, 0, len(qRecordSchema.Fields)) for _, field := range qRecordSchema.Fields { colFields = append(colFields, &protos.FieldDescription{ - Name: field.Name, + Name: utils.PostgresIdentifierNormalize(field.Name), Type: string(field.Type), TypeModifier: numeric.MakeNumericTypmod(int32(field.Precision), int32(field.Scale)), })