Fix #1662 (#1663)

continue wasn't doing anything
PeerDB-io · May 2, 2024 · 717b299 · 717b299
1 parent c1852cf
commit 717b299
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go
@@ -215,6 +215,7 @@ func (c *BigQueryConnector) ReplayTableSchemaDeltas(
 			continue
 		}
 
+	AddedColumnsLoop:
 		for _, addedColumn := range schemaDelta.AddedColumns {
 			dstDatasetTable, _ := c.convertToDatasetTable(schemaDelta.DstTableName)
 			table := c.client.DatasetInProject(c.projectID, dstDatasetTable.dataset).Table(dstDatasetTable.table)
@@ -228,7 +229,7 @@ func (c *BigQueryConnector) ReplayTableSchemaDeltas(
 				if field.Name == addedColumn.Name {
 					c.logger.Info(fmt.Sprintf("[schema delta replay] column %s already exists in table %s",
 						addedColumn.Name, schemaDelta.DstTableName))
-					continue
+					continue AddedColumnsLoop
 				}
 			}