From 4eab616e9f0a89c1a6268d5b5eaba526bfa9be6d Mon Sep 17 00:00:00 2001 From: Ying Date: Fri, 14 Apr 2023 17:39:19 -0700 Subject: [PATCH] add missing project_id in BigQueryGetDataOperator (#30651) --- airflow/providers/google/cloud/operators/bigquery.py | 1 + 1 file changed, 1 insertion(+) diff --git a/airflow/providers/google/cloud/operators/bigquery.py b/airflow/providers/google/cloud/operators/bigquery.py index 9de5663420bf6..092290a77fa30 100644 --- a/airflow/providers/google/cloud/operators/bigquery.py +++ b/airflow/providers/google/cloud/operators/bigquery.py @@ -905,6 +905,7 @@ def execute(self, context: Context): schema: dict[str, list] = hook.get_schema( dataset_id=self.dataset_id, table_id=self.table_id, + project_id=self.project_id, ) if "fields" in schema: self.selected_fields = ",".join([field["name"] for field in schema["fields"]])