add missing project_id in BigQueryGetDataOperator (#30651)

apache · Apr 15, 2023 · 4eab616 · 4eab616
1 parent d3aeb4d
commit 4eab616
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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"]])