github-actions[bot] opened a new pull request, #72614: URL: https://github.com/apache/airflow/pull/72614
* Pin triggerer start_from_trigger DAG resolution to the dagrun's version * Resolve trigger Dag version via _version_from_dag_run for pinned/unpinned parity * Skip triggers whose task is missing from the resolved Dag version For an unpinned run the resolved (latest) Dag version may no longer contain a renamed or removed deferred task. get_task() then raised TaskNotFound, which nothing on the load_triggers path caught, killing the whole triggerer; assign_unassigned re-handed the same trigger to the restarted triggerer, producing a crash loop. Guard the lookup and fall through to the plain workload, mirroring the guard in the execution API. Also introduce DBDagBag.get_serialized_dag_model_for_run so the triggerer uses a public API instead of the private _version_from_dag_run helper, as requested in review. (cherry picked from commit aead44307292bb3a927504d5ebcd9e3104b624aa) Co-authored-by: Sean Ghaeli <[email protected]> -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
