1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
# THIS FILE IS PART OF THE CYLC WORKFLOW ENGINE.
# Copyright (C) NIWA & British Crown (Met Office) & Contributors.
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>.
"""Test set, trigger, and remove command back-compat with --flow=all.
This option is now just the default (flows = ['all'] -> []).
BACK COMPAT: handle --flow=all from pre-8.5 clients
"""
import pytest
from cylc.flow.commands import (
force_trigger_tasks,
remove_tasks,
run_cmd,
set_prereqs_and_outputs,
)
from cylc.flow.exceptions import InputError
from cylc.flow.scheduler import Scheduler
from cylc.flow.task_outputs import TASK_OUTPUT_SUCCEEDED
async def test_back_compat_flow_all(flow, scheduler, start):
"""Handle --flow=all from old clients.
The trigger, set, and remove commmands no longer take --flow=all, but
for a while we need to handle that option coming in from older clients.
(Prior to 8.5 it was the schema default for remove, and was documented
as an option for set and trigger).
"""
conf = {
'scheduling': {
'graph': {
'R1': 'a & b'
},
},
}
schd: Scheduler = scheduler(flow(conf))
async with start(schd):
foo, bar = schd.pool.get_tasks()
# For comparison, set should fail with an illegal flow value (allx)
with pytest.raises(
InputError,
match="Flow values must be integers, or 'new', or 'none'"
):
await run_cmd(
set_prereqs_and_outputs(schd, [foo.identity], ['allx'])
)
# but the old --flow=all is OK - it converts to the default.
await run_cmd(
set_prereqs_and_outputs(schd, [foo.identity], ['all'])
)
assert (
TASK_OUTPUT_SUCCEEDED in foo.state.outputs.get_completed_outputs()
)
# For comparison, trigger should fail with an illegal flow value (allx)
with pytest.raises(
InputError,
match="Flow values must be integers, or 'new', or 'none'"
):
await run_cmd(
force_trigger_tasks(schd, [bar.identity], ['allx'])
)
# but the old --flow=all is OK - it converts to the default.
await run_cmd(
force_trigger_tasks(schd, [bar.identity], ['all'])
)
assert bar in schd.pool.tasks_to_trigger_now
# For comparison, remove should fail with an illegal flow value (allx)
with pytest.raises(
InputError,
match="Flow values must be integers"
):
await run_cmd(
remove_tasks(schd, [bar.identity], ['allx'])
)
# but the old --flow=all is OK - it converts to the default.
await run_cmd(
remove_tasks(schd, [bar.identity], ['all'])
)
assert bar not in schd.pool.get_tasks()
assert bar not in schd.pool.tasks_to_trigger_now
|
