From 7131709e3e3fb6e85f1aef52788b81814506b94a Mon Sep 17 00:00:00 2001 From: Chris Riccomini Date: Fri, 31 Aug 2018 10:18:29 -0700 Subject: [PATCH] [AIRFLOW-2994] Fix flatten_results for BigQueryOperator --- airflow/contrib/hooks/bigquery_hook.py | 2 +- airflow/contrib/operators/bigquery_operator.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/contrib/hooks/bigquery_hook.py b/airflow/contrib/hooks/bigquery_hook.py index e4c0653bfe278..aee84e9eef741 100644 --- 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 index bda0b08c234a2..a8fdc66ec9631 100644 --- 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,