Skip to content

Commit bcaa368

Browse files
committed
fix tests
1 parent a365a11 commit bcaa368

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

airflow-core/tests/unit/models/test_trigger.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -256,6 +256,7 @@ def get_xcoms(ti):
256256
assert actual_xcoms == expected_xcoms
257257

258258

259+
@pytest.mark.need_serialized_dag
259260
def test_assign_unassigned(session, create_task_instance):
260261
"""
261262
Tests that unassigned triggers of all appropriate states are assigned.
@@ -352,6 +353,7 @@ def test_assign_unassigned(session, create_task_instance):
352353
)
353354

354355

356+
@pytest.mark.need_serialized_dag
355357
def test_get_sorted_triggers_same_priority_weight(session, create_task_instance):
356358
"""
357359
Tests that triggers are sorted by the creation_date if they have the same priority.
@@ -416,6 +418,7 @@ def test_get_sorted_triggers_same_priority_weight(session, create_task_instance)
416418
assert trigger_ids_query == [(trigger_old.id,), (trigger_new.id,), (trigger_asset.id,)]
417419

418420

421+
@pytest.mark.need_serialized_dag
419422
def test_get_sorted_triggers_different_priority_weights(session, create_task_instance):
420423
"""
421424
Tests that triggers are sorted by the priority_weight.

0 commit comments

Comments
 (0)