ashb commented on code in PR #73554:
URL: https://github.com/apache/airflow/pull/73554#discussion_r4085098159
##########
airflow-core/src/airflow/models/taskinstance.py:
##########
@@ -1933,14 +1950,7 @@ def fetch_handle_failure_context(
if task and fail_fast:
_stop_remaining_tasks(task_instance=ti, session=session)
else:
- if ti.state != TaskInstanceState.RESTARTING:
- # Record the current attempt and prepare the TI for its next
try.
- # Covers every path eligible for retry reaching
handle_failure():
- # - RUNNING: task raised an exception during execution (normal
failure)
- # - QUEUED/SCHEDULED: executor killed the task externally
before
- # it could start (e.g. pod OOMKilled in KubernetesExecutor)
- # RESTARTING is excluded: the task was cleared via the UI/API
while running;
- # prepare_db_for_next_try() was already called during that
clear operation.
+ if ti.state != TaskInstanceState.UP_FOR_RETRY:
ti.prepare_db_for_next_try(session)
Review Comment:
New UI updates and screenshots added to the original PR
--
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]
