amoghrajesh commented on code in PR #73160:
URL: https://github.com/apache/airflow/pull/73160#discussion_r4043784245
##########
airflow-core/docs/core-concepts/tasks.rst:
##########
@@ -314,6 +314,12 @@ DAG was triggered:
return RetryDecision.fail(reason="Backfill run -- not
retrying")
return RetryDecision.default()
+A retry policy only decides whether and when a task gets another attempt; it
+has no visibility into what the task already did before it failed. For a
Review Comment:
Reworded: the policy receives the full run context and can inspect
`context["task_state_store"]` when deciding, but it never persists or restores
progress itself. Resuming from a checkpoint remains the task's own work.
##########
airflow-core/docs/core-concepts/resumable-tasks.rst:
##########
@@ -226,3 +226,42 @@ Comparison
- Airflow 2.2
- Airflow 3.3
- Airflow 3.2
+
+.. _concepts-resumable-tasks-retry-policies:
+
+Retry policies and durable execution
+-------------------------------------
+
+Durable execution, taken broadly, is fine-grained workflow control: rich
Review Comment:
Scoped the term back to the state-store meaning used earlier on the page.
The section now opens with "Long-running tasks typically need two separate
things together: a retry policy, and durable execution as defined above", and
the second paragraph is headed Durable execution rather than presenting retries
and state as two components of it.
--
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]
