edit a log in merge stmts

PeerDB-io · Feb 9, 2024 · 03fd5f3 · 03fd5f3
1 parent 3369a9b
commit 03fd5f3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go
@@ -610,7 +610,7 @@ func (c *BigQueryConnector) NormalizeRecords(req *model.NormalizeRecordsRequest)
 		mergeStmts := mergeGen.generateMergeStmts(unchangedToastColumns)
 		for i, mergeStmt := range mergeStmts {
 			c.logger.Info(fmt.Sprintf("running merge statement [%d/%d] for table %s..",
-				i+1, len(mergeStmts), tableName))
+				i+1, len(mergeStmts), tableName), slog.String("mergeStmt", mergeStmt))
 			q := c.client.Query(mergeStmt)
 			_, err = q.Read(c.ctx)
 			if err != nil {