leossantos commented on code in PR #64322:
URL: https://github.com/apache/airflow/pull/64322#discussion_r3024117388
##########
airflow-core/tests/unit/models/test_dag.py:
##########
@@ -2047,6 +2047,128 @@ def test_dags_needing_dagruns_assets(self, dag_maker,
session):
dag_models = query.all()
assert dag_models == [dag_model]
+ def test_dags_needing_dagruns_skips_adrq_when_serialized_dag_missing(
+ self, session, caplog, testing_dag_bundle
+ ):
+ """ADRQ rows for a Dag without SerializedDagModel must be skipped (no
triggered_date_by_dag).
+
+ Rows must remain in ``asset_dag_run_queue`` so the scheduler can
re-evaluate on a later run once
+ ``SerializedDagModel`` exists (``dags_needing_dagruns`` only drops
them from the in-memory
+ candidate set, it does not delete ORM rows).
+ """
+ orphan_dag_id = "adrq_no_serialized_dag"
+ orphan_uri = "test://asset_for_orphan_adrq"
+ session.add(AssetModel(uri=orphan_uri))
+ session.flush()
+ asset_id = session.scalar(select(AssetModel.id).where(AssetModel.uri
== orphan_uri))
+
+ dag_model = DagModel(
+ dag_id=orphan_dag_id,
+ bundle_name="testing",
+ max_active_tasks=1,
+ has_task_concurrency_limits=False,
+ max_consecutive_failed_dag_runs=0,
+ next_dagrun=timezone.datetime(2038, 1, 1),
+ next_dagrun_create_after=timezone.datetime(2038, 1, 2),
+ is_stale=False,
+ has_import_errors=False,
+ is_paused=False,
+ asset_expression={"any": [{"uri": orphan_uri}]},
+ )
+ session.add(dag_model)
+ session.flush()
+
+ session.add(AssetDagRunQueue(asset_id=asset_id,
target_dag_id=orphan_dag_id))
+ session.flush()
+
+ with caplog.at_level(logging.DEBUG, logger="airflow.models.dag"):
+ _query, triggered_date_by_dag =
DagModel.dags_needing_dagruns(session)
+
+ assert orphan_dag_id not in triggered_date_by_dag
+ assert "DAGs in ADRQ but missing SerializedDagModel" in caplog.text
Review Comment:
I solved this issue
<img width="1508" height="594" alt="Captura de Tela 2026-04-01 às 16 13 48"
src="https://github.com/user-attachments/assets/53017f8c-238b-4795-8b9c-7b2235e1af82";
/>
--
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]
