The GitHub Actions job "Tests" on airflow.git/fix/ti-skip-downstream-state-guard has failed. Run started by GitHub user kaxil (triggered by kaxil).
Head commit for run: 4d57ba4039af7e868ed2e28043936b2c6cf25450 / 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. related: #59378 Report URL: https://github.com/apache/airflow/actions/runs/23275891702 With regards, GitHub Actions via GitBox --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
