more error

PeerDB-io · Nov 15, 2023 · 04b1969 · 04b1969
1 parent fe3f94d
commit 04b1969
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go
@@ -775,6 +775,9 @@ func (c *SnowflakeConnector) NormalizeRecords(req *model.NormalizeRecordsRequest
 				req,
 				normalizeRecordsTx)
 			if err != nil {
+				log.WithFields(log.Fields{
+					"flowName": req.FlowJobName,
+				}).Errorf("[merge] error while normalizing records: %v", err)
 				return err
 			}