Skip to content

Commit

Permalink
Fix mixed up args
Browse files Browse the repository at this point in the history
  • Loading branch information
MetRonnie committed Sep 5, 2024
1 parent a6ce75d commit d149d09
Showing 1 changed file with 7 additions and 4 deletions.
11 changes: 7 additions & 4 deletions cylc/flow/task_pool.py
Original file line number Diff line number Diff line change
Expand Up @@ -742,7 +742,9 @@ def get_or_spawn_task(
is_xtrig_sequential = False
if ntask is None:
# ntask does not exist: spawn it in the flow.
ntask = self.spawn_task(tdef.name, point, flow_nums, flow_wait)
ntask = self.spawn_task(
tdef.name, point, flow_nums, flow_wait=flow_wait
)
# if the task was found set xtrigger checking type.
# otherwise find the xtrigger type if it can't spawn
# for whatever reason.
Expand Down Expand Up @@ -1658,7 +1660,6 @@ def spawn_task(
name: str,
point: 'PointBase',
flow_nums: Set[int],
force: bool = False,
flow_wait: bool = False,
) -> Optional[TaskProxy]:
"""Return a new task proxy for the given flow if possible.
Expand Down Expand Up @@ -1723,7 +1724,7 @@ def spawn_task(
if prev_flow_wait:
self._spawn_after_flow_wait(itask)

if itask.transient and not force:
if itask.transient:
return None

if not itask.transient:
Expand Down Expand Up @@ -2016,7 +2017,9 @@ def _set_prereqs_tdef(
):
"""Spawn a future task and set prerequisites on it."""

itask = self.spawn_task(taskdef.name, point, flow_nums, flow_wait)
itask = self.spawn_task(
taskdef.name, point, flow_nums, flow_wait=flow_wait
)
if itask is None:
return
if self._set_prereqs_itask(itask, prereqs, flow_nums):
Expand Down

0 comments on commit d149d09

Please sign in to comment.