From 390ff8aed40c7972f1c15eb76d2798af22812ff2 Mon Sep 17 00:00:00 2001
From: Amogh-Bharadwaj <amogh@peerdb.io>
Date: Mon, 16 Oct 2023 02:58:03 +0530
Subject: [PATCH] minor change

---
 flow/connectors/snowflake/qrep_avro_sync.go | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/flow/connectors/snowflake/qrep_avro_sync.go b/flow/connectors/snowflake/qrep_avro_sync.go
index 36cfef9f50..eaba46bbed 100644
--- 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 {