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

ashb · Oct 22, 2018 · e7f73d2 · e7f73d2
1 parent bde5bff
commit e7f73d2
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
@@ -472,7 +472,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,