This is an automated email from the ASF dual-hosted git repository.

potiuk 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 c86ba34f508 Documenting effect if task state store cleanup for KPO 
(#70722)
c86ba34f508 is described below

commit c86ba34f5080547e926af74c6bb46670685c00d4
Author: Amogh Desai <[email protected]>
AuthorDate: Fri Jul 31 00:49:03 2026 +0530

    Documenting effect if task state store cleanup for KPO (#70722)
---
 providers/cncf/kubernetes/docs/operators.rst | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/providers/cncf/kubernetes/docs/operators.rst 
b/providers/cncf/kubernetes/docs/operators.rst
index abdd4307aba..05da87f11dd 100644
--- a/providers/cncf/kubernetes/docs/operators.rst
+++ b/providers/cncf/kubernetes/docs/operators.rst
@@ -220,6 +220,15 @@ Durable execution requires Airflow 3.3 or newer, since it 
relies on the task sta
 earlier Airflow versions ``durable=True`` (the default) falls back to the same 
label-search
 reattach behavior this operator has always used.
 
+The pod identity persisted in task state store isn't deleted automatically, 
that only happens
+when someone runs ``airflow state-store clean``. If a task's ``retry_delay`` 
is longer than
+``[state_store] default_retention_days`` (30 days by default) and cleanup runs 
in between, the
+pod identity won't be there for the next retry, and the operator falls back to 
the label-search
+bootstrap path instead of reconnecting directly. This isn't necessarily a 
duplicate, the label
+search can often still find the same pod, but it loses the unambiguous 
reconnect and reopens
+exposure to ``FoundMoreThanOnePodFailure`` if a genuine duplicate pod exists 
by then. Avoid
+running cleanup on a schedule shorter than your longest ``retry_delay``.
+
 ``durable`` supersedes the deprecated ``reattach_on_restart`` parameter -- 
passing
 ``reattach_on_restart`` still works but emits 
``AirflowProviderDeprecationWarning`` (on Airflow
 3.3+) and maps its value onto ``durable``.

Reply via email to