[airflow] branch main updated: Fix await_container_completion condition (#23883)

[po...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

potiuk 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 42abbf0d61 Fix await_container_completion condition (#23883)
42abbf0d61 is described below

commit 42abbf0d61f94ec50026af0c0f95eb378e403042
Author: akakakakakaa <ak...@naver.com>
AuthorDate: Tue Jun 7 03:18:47 2022 +0900

    Fix await_container_completion condition (#23883)
---
 airflow/providers/cncf/kubernetes/utils/pod_manager.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/providers/cncf/kubernetes/utils/pod_manager.py b/airflow/providers/cncf/kubernetes/utils/pod_manager.py
index 27c9439dbd..83c3cead09 100644
--- a/airflow/providers/cncf/kubernetes/utils/pod_manager.py
+++ b/airflow/providers/cncf/kubernetes/utils/pod_manager.py
@@ -256,7 +256,7 @@ class PodManager(LoggingMixin):
                 time.sleep(1)
 
     def await_container_completion(self, pod: V1Pod, container_name: str) -> None:
-        while not self.container_is_running(pod=pod, container_name=container_name):
+        while self.container_is_running(pod=pod, container_name=container_name):
             time.sleep(1)
 
     def await_pod_completion(self, pod: V1Pod) -> V1Pod: