test(dag): assert full DDRQ missing-serialized log line in caplog

Author: leossantos

tests/models/test_dag.py

@@ -3096,7 +3096,10 @@ def test_dags_needing_dagruns_skips_ddrq_when_serialized_dag_missing(self, sessi
             _query, dataset_triggered_dag_info = DagModel.dags_needing_dagruns(session)
 
         assert orphan_dag_id not in dataset_triggered_dag_info
-        assert "not found in the serialized_dag table" in caplog.text
+        assert (
+            "Dags have queued dataset events (DDRQs), but are not found in the serialized_dag table."
+            in caplog.text
+        )
         assert orphan_dag_id in caplog.text
         assert (
             session.query(DatasetDagRunQueue)
@@ -3157,7 +3160,12 @@ def test_dags_needing_dagruns_missing_serialized_warning_lists_sorted_dag_ids(se
 
         assert "ghost_a" not in dataset_triggered_dag_info
         assert "ghost_z" not in dataset_triggered_dag_info
-        msg = next(r.message for r in caplog.records if "not found in the serialized_dag table" in r.message)
+        msg = next(
+            r.message
+            for r in caplog.records
+            if "Dags have queued dataset events (DDRQs), but are not found in the serialized_dag table."
+            in r.message
+        )
         assert msg.index("ghost_a") < msg.index("ghost_z")
         assert (
             session.query(DatasetDagRunQueue)