The GitHub Actions job "Check newsfragment PR number" on 
airflow.git/fix/scheduler-fail-queued-dagrun-unresolvable-version has failed.
Run started by GitHub user kjh0623 (triggered by potiuk).

Head commit for run:
1d76037ff44a1abe91d6bbad2ce20888843be088 / kjh0623 
<[email protected]>
Fail queued DagRuns whose pinned dag version can no longer be resolved

A DagRun created pinned to a dag version (bundle_version set,
created_dag_version_id populated) becomes unresolvable if that dag_version row
is later deleted: the FK's ondelete="set null" clears created_dag_version_id
while bundle_version stays set, so the pinned resolver returns None (it only
falls back to the latest version for unpinned runs). _start_queued_dagruns then
could not resolve the serialized DAG and skipped the run with
"DAG '...' not found in serialized_dag table" on every loop - the run was
neither started nor failed and stayed QUEUED indefinitely, with no failure
signal and a misleading log (the DAG is in serialized_dag; the pinned version
is not).

Fail such a run explicitly, mirroring how a SCHEDULED task instance whose
serialized DAG cannot be found is already failed in the same loop. Add a
regression test that the pinned-unresolvable run reaches FAILED instead of
being skipped forever, plus a contrast test that an unpinned run with the same
NULL created_dag_version_id still falls back to the latest version and starts.

Signed-off-by: kjh0623 <[email protected]>

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

With regards,
GitHub Actions via GitBox


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

Reply via email to