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 <[email protected]> Authored: Wed Oct 18 21:53:33 2017 +0200 Committer: Bolke de Bruin <[email protected]> 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): """
