github-actions[bot] opened a new pull request, #64738: URL: https://github.com/apache/airflow/pull/64738
* fix(scheduler): skip asset-triggered dags without SerializedDagModel in dags_needing_dagruns Remove those dag_ids from the in-memory candidate set until serialization exists; retain AssetDagRunQueue rows and emit DEBUG logs. Add unit tests and a bugfix newsfragment. * fix(scheduler): prevent premature asset-triggered DagRuns when SerializedDagModel is unavailable * test(dag): persist DagModel before AssetDagRunQueue in unit tests Split DagModel and AssetDagRunQueue inserts and flush after DagModel so foreign-key order matches production DB constraints in TestDagModel. * Apply suggestions from code review Co-authored-by: Wei Lee <[email protected]> * refactor(dag): clarify ADRQ skip log and condense serialized-DAG guard Combine the missing-from-serialized set check with a walrus assignment and improve the debug message when DagRun creation is skipped for DAGs with queued asset events but no SerializedDagModel row. * test(models): align caplog assertions with updated serialized dag warnings * test(dag): align ADRQ missing-serialized log assertion with message text * Apply suggestion from @jscheffl Co-authored-by: Jens Scheffler <[email protected]> * chore(newsfragments): remove 64322.bugfix.rst --------- (cherry picked from commit b91394aa4ccd94c34fb4c1b8d82c9b24c9577fbe) Co-authored-by: Leonardo Soares <[email protected]> Co-authored-by: Wei Lee <[email protected]> Co-authored-by: Jens Scheffler <[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]
