This is an automated email from the ASF dual-hosted git repository.
jscheffl 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 16bc6df4ae6 fixed an issue that caused a state mismatch (#63061)
16bc6df4ae6 is described below
commit 16bc6df4ae6ced6237cf2c532fe99225b3bd06c0
Author: Nataneljpwd <[email protected]>
AuthorDate: Sat Mar 7 23:59:12 2026 +0200
fixed an issue that caused a state mismatch (#63061)
---
.../providers/cncf/kubernetes/executors/kubernetes_executor.py | 1 +
.../unit/cncf/kubernetes/executors/test_kubernetes_executor.py | 10 ++++++++++
2 files changed, 11 insertions(+)
diff --git
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
index bb94c76c447..a55341a62a8 100644
---
a/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
+++
b/providers/cncf/kubernetes/src/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
@@ -337,6 +337,7 @@ class KubernetesExecutor(BaseExecutor):
if (
(str(e.status) == "403" and "exceeded quota" in
message)
or (str(e.status) == "409" and "object has been
modified" in message)
+ or (str(e.status) == "410" and "too old resource
version" in message)
or str(e.status) == "500"
) and (self.task_publish_max_retries == -1 or retries <
self.task_publish_max_retries):
self.log.warning(
diff --git
a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/executors/test_kubernetes_executor.py
b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/executors/test_kubernetes_executor.py
index 86cfdedc49b..af4a503c66c 100644
---
a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/executors/test_kubernetes_executor.py
+++
b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/executors/test_kubernetes_executor.py
@@ -398,6 +398,16 @@ class TestKubernetesExecutor:
State.SUCCESS,
id="409 conflict",
),
+ pytest.param(
+ HTTPResponse(
+ body='{"message": "too old resource version: 65442975
(65489651)"}',
+ status=410,
+ ),
+ 1,
+ True,
+ State.SUCCESS,
+ id="410 gone",
+ ),
pytest.param(
HTTPResponse(body="Too many requests, please try again
later.", status=429),
0,
