minor change

PeerDB-io · Oct 15, 2023 · 390ff8a · 390ff8a
1 parent 47932d5
commit 390ff8a
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/flow/connectors/snowflake/qrep_avro_sync.go b/flow/connectors/snowflake/qrep_avro_sync.go
@@ -270,7 +270,11 @@ func (sc *SnowflakeConnector) GetCopyTransformation(dstTableName string) (*CopyI
 			continue
 		}
 		colName := strings.ToLower(col)
-		columnOrder = append(columnOrder, fmt.Sprintf("\"%s\"", colName))
+		// No need to quote raw table columns
+		if !strings.Contains(dstTableName, "_PEERDB_RAW") {
+			colName = fmt.Sprintf("\"%s\"", colName)
+		}
+		columnOrder = append(columnOrder, colName)
 		log.Infof("colName: %s has type: %s", colName, colType)
 
 		switch colType {