You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by bo...@apache.org on 2017/10/18 19:54:16 UTC
incubator-airflow git commit: [AIRFLOW-1694] Stop using itertools.izip
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 <ys...@fastmail.nl>
Authored: Wed Oct 18 21:53:33 2017 +0200
Committer: Bolke de Bruin <bo...@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):
"""