Skip to content

Commit 28fc730

Browse files
committed
Address review comments.
1 parent 4afec54 commit 28fc730

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

cylc/flow/task_pool.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1888,7 +1888,7 @@ def _standardise_prereqs(self, prereqs: 'List[str]') -> 'Set[PrereqTuple]':
18881888
LOG.warning(
18891889
f'Invalid prerequisite cycle point:\n{exc.args[0]}')
18901890
else:
1891-
_prereqs.add(PrereqTuple(str(cycle), str(pre.task), msg))
1891+
_prereqs.add(PrereqTuple(str(cycle), str(pre["task"]), msg))
18921892
return _prereqs
18931893

18941894
def _standardise_outputs(
@@ -2049,7 +2049,7 @@ def _get_valid_prereqs(
20492049
set of tokens {(cycle, task, task_message),}
20502050
20512051
"""
2052-
valid = {pre.keys() for pre in tdef.get_prereqs(point)}
2052+
valid = {key for pre in tdef.get_prereqs(point) for key in pre.keys()}
20532053

20542054
# Get prerequisite tuples in terms of task messages not triggers.
20552055
requested = self._standardise_prereqs(prereqs)
@@ -2064,7 +2064,7 @@ def _get_valid_prereqs(
20642064
f'"{prereq.get_id()}:{trg}"'
20652065
)
20662066
return {
2067-
Tokens(cycle=pre.cycle, task=pre.task, task_sel=pre.output)
2067+
Tokens(cycle=pre.point, task=pre.task, task_sel=pre.output)
20682068
for pre in valid & requested
20692069
}
20702070

0 commit comments

Comments
 (0)