airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From bo...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-1694] Stop using itertools.izip
Date Wed, 18 Oct 2017 19:54:16 GMT
Repository: incubator-airflow
Updated Branches:
  refs/heads/master 2da485681 -> 6110139a8


[AIRFLOW-1694] Stop using itertools.izip

Itertools.zip does not exist in Python 3.

Closes #2674 from yati-sagade/fix-py3-zip


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

Branch: refs/heads/master
Commit: 6110139a8fd7069c87e3c99b3976865576180f67
Parents: 2da4856
Author: Yati Sagade <ysagade@fastmail.nl>
Authored: Wed Oct 18 21:53:33 2017 +0200
Committer: Bolke de Bruin <bolke@xs4all.nl>
Committed: Wed Oct 18 21:53:36 2017 +0200

----------------------------------------------------------------------
 airflow/hooks/hive_hooks.py | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/6110139a/airflow/hooks/hive_hooks.py
----------------------------------------------------------------------
diff --git a/airflow/hooks/hive_hooks.py b/airflow/hooks/hive_hooks.py
index 7c73491..a8f9c8f 100644
--- a/airflow/hooks/hive_hooks.py
+++ b/airflow/hooks/hive_hooks.py
@@ -14,7 +14,7 @@
 #
 
 from __future__ import print_function
-from builtins import zip
+from six.moves import zip
 from past.builtins import basestring
 
 import unicodecsv as csv
@@ -144,11 +144,9 @@ class HiveCliHook(BaseHook):
         if not d:
             return []
         return as_flattened_list(
-            itertools.izip(
-                ["-hiveconf"] * len(d),
-                ["{}={}".format(k, v) for k, v in d.items()]
-                )
-            )
+            zip(["-hiveconf"] * len(d),
+                ["{}={}".format(k, v) for k, v in d.items()])
+        )
 
     def run_cli(self, hql, schema=None, verbose=True, hive_conf=None):
         """


Mime
View raw message