The GitHub Actions job "Tests AMD" on airflow.git/fix-clearing-when-running has succeeded. Run started by GitHub user kaxil (triggered by kaxil).
Head commit for run: e51dbe16a5aef8c0735212ff3a3e8afbc55cc336 / Kaxil Naik <[email protected]> Fix scheduler processing of cleared running tasks stuck in RESTARTING state Clearing a DAG with running tasks causes them to get stuck in RESTARTING state indefinitely with continuous heartbeat timeout events. This was a regression in Airflow 3.x where the scheduler failed to process executor completion events for RESTARTING tasks. The scheduler's _process_executor_events() function has two gatekeeping mechanisms that filter executor events, both of which were missing TaskInstanceState.RESTARTING. This caused the scheduler to ignore when tasks in RESTARTING state were successfully terminated by the executor. Changes: - Add RESTARTING to executor event processing filters in scheduler - Add special handling for successful termination of RESTARTING tasks - Set RESTARTING tasks to None (scheduled) state with adjusted max_tries - Update task lifecycle diagram to reflect RESTARTING → None transition - Add regression test for max_tries edge case with proper mock spec This ensures cleared running tasks can retry immediately without getting stuck, consistent with clearing behavior for non-running tasks. Fixes #55045 Report URL: https://github.com/apache/airflow/actions/runs/17335214100 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
