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 dba3e4ec51 Revert "Fix await_container_completion condition (#23883)"
(#24474)
dba3e4ec51 is described below
commit dba3e4ec51c03dc08449a3954fa3539388d0bc73
Author: Jed Cunningham <[email protected]>
AuthorDate: Wed Jun 15 10:22:49 2022 -0600
Revert "Fix await_container_completion condition (#23883)" (#24474)
This reverts commit 42abbf0d61f94ec50026af0c0f95eb378e403042.
---
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 83c3cead09..27c9439dbd 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 self.container_is_running(pod=pod,
container_name=container_name):
+ while not self.container_is_running(pod=pod,
container_name=container_name):
time.sleep(1)
def await_pod_completion(self, pod: V1Pod) -> V1Pod:
