This is an automated email from the ASF dual-hosted git repository.
husseinawala 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 f5259376b8 Use fail instead of change_state(failed) in K8S executor
(#35900)
f5259376b8 is described below
commit f5259376b8e7155e21ba0ec15eb192f13e618291
Author: Hussein Awala <[email protected]>
AuthorDate: Tue Nov 28 10:10:10 2023 +0200
Use fail instead of change_state(failed) in K8S executor (#35900)
---
airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
index 2e79eee695..16923d63e2 100644
--- a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
+++ b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
@@ -423,7 +423,7 @@ class KubernetesExecutor(BaseExecutor):
if e.status in (400, 422):
self.log.error("Pod creation failed with reason %r.
Failing task", e.reason)
key, _, _, _ = task
- self.change_state(key, TaskInstanceState.FAILED, e)
+ self.fail(key, e)
else:
self.log.warning(
"ApiException when attempting to run task,
re-queueing. Reason: %r. Message: %s",
