From 52c1bd6c43573ced50937c38f496ace50d166b6f 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"]])