revert partially

PeerDB-io · Feb 9, 2024 · 899ad6c · 899ad6c
1 parent c588b71
commit 899ad6c
Showing 1 changed file with 7 additions and 8 deletions.
diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go
@@ -7,7 +7,6 @@ import (
 	"log/slog"
 	"reflect"
 	"regexp"
-	"slices"
 	"strings"
 	"time"
 
@@ -461,13 +460,13 @@ func (c *BigQueryConnector) getTableNametoUnchangedCols(flowJobName string, sync
 	// Create a map to store the results.
 	resultMap := make(map[string][]string)
 
-	for {
-		// Process the query results using an iterator.
-		var row struct {
-			Tablename             string   `bigquery:"_peerdb_destination_table_name"`
-			UnchangedToastColumns []string `bigquery:"unchanged_toast_columns"`
-		}
+	// Process the query results using an iterator.
+	var row struct {
+		Tablename             string   `bigquery:"_peerdb_destination_table_name"`
+		UnchangedToastColumns []string `bigquery:"unchanged_toast_columns"`
+	}
 
+	for {
 		err := it.Next(&row)
 		if err == iterator.Done {
 			break
@@ -476,7 +475,7 @@ func (c *BigQueryConnector) getTableNametoUnchangedCols(flowJobName string, sync
 			return nil, err
 		}
 
-		resultMap[row.Tablename] = slices.Clone(row.UnchangedToastColumns)
+		resultMap[row.Tablename] = row.UnchangedToastColumns
 		c.logger.Info("unchanged toast columns",
 			slog.String("table", row.Tablename),
 			slog.Any("columns", row.UnchangedToastColumns),