fix setupnormalize

PeerDB-io · Dec 3, 2024 · 52952cc · 52952cc
1 parent f777f97
commit 52952cc
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go
@@ -649,10 +649,11 @@ func (c *BigQueryConnector) SetupNormalizedTable(
 				slog.Any("existingMetadata", existingMetadata))
 			return true, nil
 		}
-	}
-	if !strings.Contains(err.Error(), "notFound") {
-		return false, fmt.Errorf("error while checking metadata for BigQuery table existence %s: %w",
-			tableIdentifier, err)
+	} else {
+		if !strings.Contains(err.Error(), "notFound") {
+			return false, fmt.Errorf("error while checking metadata for BigQuery table existence %s: %w",
+				tableIdentifier, err)
+		}
 	}
 
 	// convert the column names and types to bigquery types