more fix

PeerDB-io · Feb 7, 2024 · 72bac59 · 72bac59
1 parent 3e5c4b9
commit 72bac59
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go
@@ -861,6 +861,9 @@ func (c *BigQueryConnector) SetupNormalizedTables(
 			// table exists, go to next table
 			tableExistsMapping[tableIdentifier] = true
 			datasetTablesSet[*datasetTable] = struct{}{}
+
+			c.logger.Info(fmt.Sprintf("table already exists %s", tableIdentifier))
+			numTablesSetup.Add(1)
 			continue
 		}