Skip to content

Commit d3f5f68

Browse files
committed
Add back simple trigger while paused test
1 parent 9401a1a commit d3f5f68

File tree

1 file changed

+15
-10
lines changed

1 file changed

+15
-10
lines changed

tests/integration/test_force_trigger.py

Lines changed: 15 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,17 @@
4242
)
4343

4444

45-
async def test_trigger_workflow_paused(
45+
async def test_workflow_paused_simple(
46+
one_conf, flow, scheduler, run, complete
47+
):
48+
"""It should run triggered tasks even if the workflow is paused."""
49+
schd: Scheduler = scheduler(flow(one_conf), paused_start=True)
50+
async with run(schd):
51+
await run_cmd(force_trigger_tasks(schd, ['1/one'], ['1']))
52+
await complete(schd, '1/one', allow_paused=True, timeout=1)
53+
54+
55+
async def test_workflow_paused_queues(
4656
flow: 'Fixture',
4757
scheduler: 'Fixture',
4858
start: 'Fixture',
@@ -111,22 +121,17 @@ async def test_trigger_workflow_paused(
111121

112122

113123
async def test_trigger_group_whilst_paused(flow, scheduler, run, complete):
114-
"""Only group start tasks should run whilst the scheduler is paused.
124+
"""Only group start tasks should run if the group is triggered whilst
125+
the scheduler is paused.
115126
116127
Group start tasks have only off-group dependencies.
117128
118129
Others (with in-group dependencies) should run as normal when their
119130
prerequisites are satisfied once the workflow is resumed.
120131
121132
"""
122-
id_ = flow(
123-
{
124-
'scheduling': {
125-
'graph': {'R1': 'a => b => c => d'},
126-
},
127-
}
128-
)
129-
schd = scheduler(id_)
133+
id_ = flow('a => b => c => d')
134+
schd = scheduler(id_, paused_start=True)
130135
async with run(schd):
131136
# trigger the chain
132137
await run_cmd(force_trigger_tasks(schd, ['1/a'], []))

0 commit comments

Comments
 (0)