wolfdn commented on code in PR #64962:
URL: https://github.com/apache/airflow/pull/64962#discussion_r3080002358
##########
providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/operators/pod.py:
##########
@@ -1110,9 +1110,12 @@ def cleanup(
):
self.patch_already_checked(remote_pod, reraise=False)
- failed = (pod_phase != PodPhase.SUCCEEDED and not istio_enabled) or (
- istio_enabled and not container_is_succeeded(remote_pod,
self.base_container_name)
- )
+ if istio_enabled or self.do_xcom_push:
+ failed = pod_phase != PodPhase.SUCCEEDED and not
container_is_succeeded(
+ remote_pod, self.base_container_name
+ )
Review Comment:
Applied in ff0173b7eb887752b317f119ff4d81c3e5ce0310
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
