in bigquery/main.go [318:331]
func (bq *actualBQ) EnsureDataset(ctx context.Context, datasetName string) error {
// Check for existence of dataset, create if false
bq.dataset = bq.client.Dataset(datasetName)
_, err := bq.client.Dataset(datasetName).Metadata(ctx)
if err != nil {
log.Warningf("error obtaining dataset metadata: %v;Creating new BigQuery dataset: %q", err, datasetName)
if err := bq.dataset.Create(ctx, &bigquery.DatasetMetadata{
Name: datasetName, Description: "BigQuery Notifier Build Data",
}); err != nil {
return fmt.Errorf("error creating dataset: %v", err)
}
}
return nil
}