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"]])