This is an automated email from the ASF dual-hosted git repository.
uranusjr pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new f66df7f6bc Replace dict.items by values when key is not used in
providers (#33939)
f66df7f6bc is described below
commit f66df7f6bc8a6ec6826bbfe8f66f58a8dde5f471
Author: Hussein Awala <[email protected]>
AuthorDate: Thu Aug 31 05:38:47 2023 +0200
Replace dict.items by values when key is not used in providers (#33939)
---
.../providers/cncf/kubernetes/executors/kubernetes_executor_utils.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_utils.py
b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_utils.py
index 099eceda0b..f8868dff44 100644
--- a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_utils.py
+++ b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_utils.py
@@ -479,7 +479,7 @@ class AirflowKubernetesScheduler(LoggingMixin):
def terminate(self) -> None:
"""Terminates the watcher."""
self.log.debug("Terminating kube_watchers...")
- for namespace, kube_watcher in self.kube_watchers.items():
+ for kube_watcher in self.kube_watchers.values():
kube_watcher.terminate()
kube_watcher.join()
self.log.debug("kube_watcher=%s", kube_watcher)