Skip to content

Commit

Permalink
[AIRFLOW-6020] Fix python 3 KubernetesExecutor iteritems exception (a…
Browse files Browse the repository at this point in the history
  • Loading branch information
eserdyuk-exos authored and kaxil committed Nov 23, 2019
1 parent 391dc97 commit db4be19
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions airflow/executors/kubernetes_executor.py
Original file line number Diff line number Diff line change
Expand Up @@ -274,7 +274,7 @@ def _run(self, kube_client, resource_version, worker_uuid, kube_config):
if resource_version:
kwargs['resource_version'] = resource_version
if kube_config.kube_client_request_args:
for key, value in kube_config.kube_client_request_args.iteritems():
for key, value in kube_config.kube_client_request_args.items():
kwargs[key] = value

last_resource_version = None
Expand Down Expand Up @@ -652,7 +652,7 @@ def clear_not_launched_queued_tasks(self, session=None):
# pylint: enable=protected-access
kwargs = dict(label_selector=dict_string)
if self.kube_config.kube_client_request_args:
for key, value in self.kube_config.kube_client_request_args.iteritems():
for key, value in self.kube_config.kube_client_request_args.items():
kwargs[key] = value
pod_list = self.kube_client.list_namespaced_pod(
self.kube_config.kube_namespace, **kwargs)
Expand Down

0 comments on commit db4be19

Please sign in to comment.