dabla commented on code in PR #62922:
URL: https://github.com/apache/airflow/pull/62922#discussion_r4027250227
##########
task-sdk/src/airflow/sdk/execution_time/task_runner.py:
##########
@@ -891,6 +906,85 @@ def mark_success_url(self) -> str:
return self.log_url
+@dataclass
+class IndexedTaskState:
+ status: TaskInstanceState
+ try_number: int
Review Comment:
No per-index budget is planned: sub-tasks inherit the parent's `try_number`
on purpose so the attempt Airflow reports and the one the sub-task sees agree.
The field is removed in cf0837f076; `deserialize` ignores it on older rows.
That also removes the off-by-one on the failure path, where the executor
incremented `try_number` before the checkpoint was written, since nothing is
stored to be off by anymore.
---
Drafted-by: Claude Fable 5.1; reviewed by @dabla before posting
--
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]
