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 57ab6c75b9ebad37395ddf8c6f14f6301e5a64b2
--
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]
