From ce505bdf8683ef6fcb61d4c35fd4cd3c0f218be9 Mon Sep 17 00:00:00 2001 From: Hussein Awala Date: Mon, 28 Aug 2023 23:18:32 +0200 Subject: [PATCH 1/2] replace unacessary dict comprehension by dict() in providers --- airflow/providers/google/cloud/operators/bigquery.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/providers/google/cloud/operators/bigquery.py b/airflow/providers/google/cloud/operators/bigquery.py index ae7e48eed7978..2d3108a6fd5c0 100644 --- a/airflow/providers/google/cloud/operators/bigquery.py +++ b/airflow/providers/google/cloud/operators/bigquery.py @@ -1039,7 +1039,7 @@ def execute(self, context: Context): self.log.info("Total extracted rows: %s", len(rows)) if self.as_dict: - table_data = [{k: v for k, v in row.items()} for row in rows] + table_data = [dict(row.items()) for row in rows] else: table_data = [row.values() for row in rows] From 8dc16acf79559b85f35bfb4a01254fcd5799a97e Mon Sep 17 00:00:00 2001 From: Hussein Awala Date: Tue, 29 Aug 2023 21:52:26 +0200 Subject: [PATCH 2/2] Update airflow/providers/google/cloud/operators/bigquery.py Co-authored-by: Tzu-ping Chung --- airflow/providers/google/cloud/operators/bigquery.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/providers/google/cloud/operators/bigquery.py b/airflow/providers/google/cloud/operators/bigquery.py index 2d3108a6fd5c0..550c4096aa540 100644 --- a/airflow/providers/google/cloud/operators/bigquery.py +++ b/airflow/providers/google/cloud/operators/bigquery.py @@ -1039,7 +1039,7 @@ def execute(self, context: Context): self.log.info("Total extracted rows: %s", len(rows)) if self.as_dict: - table_data = [dict(row.items()) for row in rows] + table_data = [dict(row) for row in rows] else: table_data = [row.values() for row in rows]