add missing project_id in BigQueryGetDataOperator (#30651)

ying-w · web-flow · commit 4eab616e9f0a · 2023-04-15T02:39:19.000+02:00
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"]])

Original file line number	Diff line number	Diff line change
`@@ -905,6 +905,7 @@ def execute(self, context: Context):`
`905`	`905`	`schema: dict[str, list] = hook.get_schema(`
`906`	`906`	`dataset_id=self.dataset_id,`
`907`	`907`	`table_id=self.table_id,`
	`908`	`+ project_id=self.project_id,`
`908`	`909`	`)`
`909`	`910`	`if "fields" in schema:`
`910`	`911`	`self.selected_fields = ",".join([field["name"] for field in schema["fields"]])`