You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by sa...@apache.org on 2017/09/06 23:44:35 UTC

incubator-airflow git commit: [AIRFLOW-1568] Fix typo in BigQueryHook

Repository: incubator-airflow
Updated Branches:
  refs/heads/master b2e1753f5 -> 03af6105e


[AIRFLOW-1568] Fix typo in BigQueryHook

Closes #2575 from jgao54/ds-import-export


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/03af6105
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/03af6105
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/03af6105

Branch: refs/heads/master
Commit: 03af6105e8a0c36666a3e30e31d088df86d4be61
Parents: b2e1753
Author: Joy Gao <jo...@wepay.com>
Authored: Wed Sep 6 16:44:31 2017 -0700
Committer: Alex Guziel <al...@airbnb.com>
Committed: Wed Sep 6 16:44:31 2017 -0700

----------------------------------------------------------------------
 airflow/contrib/hooks/bigquery_hook.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/03af6105/airflow/contrib/hooks/bigquery_hook.py
----------------------------------------------------------------------
diff --git a/airflow/contrib/hooks/bigquery_hook.py b/airflow/contrib/hooks/bigquery_hook.py
index d7c1126..dd22671 100644
--- a/airflow/contrib/hooks/bigquery_hook.py
+++ b/airflow/contrib/hooks/bigquery_hook.py
@@ -505,8 +505,8 @@ class BigQueryBaseCursor(object):
 
         # if following fields are not specified in src_fmt_configs,
         # honor the top-level params for backward-compatibility
-        if 'skip_leading_rows' not in src_fmt_configs:
-            src_fmt_configs['skip_leading_rows'] = skip_leading_rows
+        if 'skipLeadingRows' not in src_fmt_configs:
+            src_fmt_configs['skipLeadingRows'] = skip_leading_rows
         if 'fieldDelimiter' not in src_fmt_configs:
             src_fmt_configs['fieldDelimiter'] = field_delimiter
         if quote_character: