This is an automated email from the ASF dual-hosted git repository.
husseinawala pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 4eab616e9f add missing project_id in BigQueryGetDataOperator (#30651)
4eab616e9f is described below
commit 4eab616e9f0a89c1a6268d5b5eaba526bfa9be6d
Author: Ying <[email protected]>
AuthorDate: Fri Apr 14 17:39:19 2023 -0700
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 9de5663420..092290a77f 100644
--- a/airflow/providers/google/cloud/operators/bigquery.py
+++ b/airflow/providers/google/cloud/operators/bigquery.py
@@ -905,6 +905,7 @@ class BigQueryGetDataOperator(GoogleCloudBaseOperator):
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"]])
