Revert "Fix await_container_completion condition (apache#23883)"

This reverts commit 42abbf0.
astronomer · Jun 15, 2022 · 0092761 · 0092761
1 parent 952a5ea
commit 0092761
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/providers/cncf/kubernetes/utils/pod_manager.py b/airflow/providers/cncf/kubernetes/utils/pod_manager.py
@@ -256,7 +256,7 @@ def consume_logs(*, since_time: Optional[DateTime] = None, follow: bool = True)
                 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: