diff --git a/airflow/providers/google/cloud/hooks/bigquery.py b/airflow/providers/google/cloud/hooks/bigquery.py index 731cd6364bf79..6776942fc5c0b 100644 --- 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.')