The GitHub Actions job "Tests" on airflow.git/update-dagbag-to-tuple-keys has 
failed.
Run started by GitHub user ephraimbuddy (triggered by ephraimbuddy).

Head commit for run:
a24699c491fed3fc2bafb198a569ca691b8a259b / Ephraim Anierobi 
<[email protected]>
Fix task removal when there's serdag change in versioned bundle

Ensure DAG runs in a versioned bundle use the correct serialized DAG (serdag) 
version.

Previously, when a DAG had multiple versions due to changes (e.g., a task 
removed),
running DAG runs would sometimes incorrectly use the latest serialized DAG, 
even if
they were started with an older version. This caused tasks that should still run
to be incorrectly marked as removed.

The issue was caused by the scheduler not considering `bundle_version` when 
retrieving
the DAG from the `dagbag`, defaulting to the latest available version.

This fix updates `dagbag.dags` to store DAGs keyed by both `dag_id` and 
`bundle_version`.
All DAG retrievals in scheduling are now made with the correct
version context, ensuring task consistency for running DAG runs.

Also introduces a `GetDag` Protocol for precise typing of the cached DAG getter,
now supporting both `dag_id` and `bundle_version` parameters.

Report URL: https://github.com/apache/airflow/actions/runs/14338635137

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to