diff --git a/airflow/providers/google/cloud/operators/bigquery.py b/airflow/providers/google/cloud/operators/bigquery.py index ae7e48eed7978..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 = [{k: v for k, v in row.items()} for row in rows] + table_data = [dict(row) for row in rows] else: table_data = [row.values() for row in rows]