Skip to content

Commit 1f86594

Browse files
criccominiAlice Berard
authored and
Alice Berard
committed
[AIRFLOW-2994] Fix flatten_results for BigQueryOperator (apache#3829)
1 parent 4c3119a commit 1f86594

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

airflow/contrib/hooks/bigquery_hook.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -476,7 +476,7 @@ def run_query(self,
476476
destination_dataset_table=False,
477477
write_disposition='WRITE_EMPTY',
478478
allow_large_results=False,
479-
flatten_results=False,
479+
flatten_results=None,
480480
udf_config=False,
481481
use_legacy_sql=None,
482482
maximum_billing_tier=None,

airflow/contrib/operators/bigquery_operator.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -106,7 +106,7 @@ def __init__(self,
106106
destination_dataset_table=False,
107107
write_disposition='WRITE_EMPTY',
108108
allow_large_results=False,
109-
flatten_results=False,
109+
flatten_results=None,
110110
bigquery_conn_id='bigquery_default',
111111
delegate_to=None,
112112
udf_config=False,

0 commit comments

Comments
 (0)