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)

Reply via email to