Check the dataset/table exist at startup

beeper · Dec 12, 2023 · 7279cc0 · 7279cc0
1 parent eeaadf5
commit 7279cc0
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/internal/bigquery.go b/internal/bigquery.go
@@ -36,7 +36,17 @@ func getBigQueryTableInserter(cfg config.BigQueryConfig) (*bigquery.Inserter, er
 	}
 
 	dataset := client.Dataset(cfg.Dataset)
+	_, err = dataset.Metadata(context.Background())
+	if err != nil {
+		return nil, err
+	}
+
 	table := dataset.Table(cfg.Table)
+	_, err = table.Metadata(context.Background())
+	if err != nil {
+		return nil, err
+	}
+
 	return table.Inserter(), nil
 }