Use project_id to get authenticated client (#25984)

apache · Aug 27, 2022 · d4eb607 · d4eb607
1 parent b75797e
commit d4eb607
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/airflow/providers/google/cloud/hooks/bigquery.py b/airflow/providers/google/cloud/hooks/bigquery.py
@@ -448,12 +448,13 @@ def create_empty_dataset(
  dataset_reference["datasetReference"][param] = value
 
  location = location or self.location
+ project_id = project_id or self.project_id
  if location:
  dataset_reference["location"] = dataset_reference.get("location", location)
 
  dataset: Dataset = Dataset.from_api_repr(dataset_reference)
  self.log.info('Creating dataset: %s in project: %s ', dataset.dataset_id, dataset.project)
- dataset_object = self.get_client(location=location).create_dataset(
+ dataset_object = self.get_client(project_id=project_id, location=location).create_dataset(
  dataset=dataset, exists_ok=exists_ok
  )
  self.log.info('Dataset created successfully.')