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 <[email protected]>
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:
