The GitHub Actions job "Tests" on airflow.git/fix/ti-skip-downstream-state-guard has failed. Run started by GitHub user sam-dumont (triggered by sam-dumont).
Head commit for run: f4a3ded1773f730f234ded9044f884b7d0470682 / Sam Dumont <[email protected]> Fix ti_skip_downstream overwriting RUNNING tasks to SKIPPED In HA deployments, ti_skip_downstream() issues a bulk UPDATE without a state guard. When a BranchOperator decides to skip downstream tasks, it can overwrite a task already RUNNING on a worker to SKIPPED, causing a 409 heartbeat conflict that kills the task mid-execution. Add a skippable_state_clause to the UPDATE WHERE clause so RUNNING, SUCCESS, and FAILED tasks are never overwritten to SKIPPED. QUEUED tasks are intentionally allowed to be skipped: no work has been done yet and the BranchOperator's decision should take priority. The worker pod will get a benign 409 on PATCH /run and exit cleanly. closes: #59378 Report URL: https://github.com/apache/airflow/actions/runs/22905174210 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
