Use fail instead of change_state(failed) in K8S executor (#35900)

apache · Nov 28, 2023 · f525937 · f525937
1 parent 930f165
commit f525937
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
@@ -423,7 +423,7 @@ def sync(self) -> None:
                     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",