diff --git a/airflow/contrib/hooks/bigquery_hook.py b/airflow/contrib/hooks/bigquery_hook.py index d300dbe6b7095..ed97596a78a24 100644 --- a/airflow/contrib/hooks/bigquery_hook.py +++ b/airflow/contrib/hooks/bigquery_hook.py @@ -832,8 +832,8 @@ def run_copy(self, def run_load(self, destination_project_dataset_table, - source_uris, schema_fields=None, + source_uris, source_format='CSV', create_disposition='CREATE_IF_NEEDED', skip_leading_rows=0,