[AIRFLOW-2994] Fix flatten_results for BigQueryOperator (#3829)

apache · Aug 31, 2018 · 98a7874 · 98a7874
1 parent ba27fca
commit 98a7874
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/airflow/contrib/hooks/bigquery_hook.py b/airflow/contrib/hooks/bigquery_hook.py
@@ -476,7 +476,7 @@ def run_query(self,
                   destination_dataset_table=False,
                   write_disposition='WRITE_EMPTY',
                   allow_large_results=False,
-                  flatten_results=False,
+                  flatten_results=None,
                   udf_config=False,
                   use_legacy_sql=None,
                   maximum_billing_tier=None,

diff --git a/airflow/contrib/operators/bigquery_operator.py b/airflow/contrib/operators/bigquery_operator.py
@@ -106,7 +106,7 @@ def __init__(self,
                  destination_dataset_table=False,
                  write_disposition='WRITE_EMPTY',
                  allow_large_results=False,
-                 flatten_results=False,
+                 flatten_results=None,
                  bigquery_conn_id='bigquery_default',
                  delegate_to=None,
                  udf_config=False,