From e7f73d20462964bf104c7508d3f3d669e7797e49 Mon Sep 17 00:00:00 2001 From: Chris Riccomini Date: Fri, 31 Aug 2018 12:42:43 -0700 Subject: [PATCH] [AIRFLOW-2994] Fix flatten_results for BigQueryOperator (#3829) --- 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 aa8fc382a6a67..6db0c00bdd9d2 100644 --- 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 index 09f442ae7b1a6..9ec1f992c11d8 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,