Skip to content

Commit

Permalink
Update cylc/flow/task_pool.py
Browse files Browse the repository at this point in the history
Co-authored-by: Ronnie Dutta <[email protected]>
  • Loading branch information
hjoliver and MetRonnie authored Dec 10, 2024
1 parent b6c46d6 commit bd0e7ca
Showing 1 changed file with 5 additions and 7 deletions.
12 changes: 5 additions & 7 deletions cylc/flow/task_pool.py
Original file line number Diff line number Diff line change
Expand Up @@ -2171,16 +2171,14 @@ def _force_trigger(self, itask: 'TaskProxy', on_resume: bool = False):
itask.waiting_on_job_prep = True

if on_resume:
with suppress(KeyError):
# In case previously triggered without --on-resume.
# (It should have run already, but just in case).
self.tasks_to_trigger_now.remove(itask)
self.tasks_to_trigger_on_resume.add(itask)

Check warning on line 2174 in cylc/flow/task_pool.py

View check run for this annotation

Codecov / codecov/patch

cylc/flow/task_pool.py#L2174

Added line #L2174 was not covered by tests
# In case previously triggered without --on-resume.
# (It should have run already, but just in case).
self.tasks_to_trigger_now.discard(itask)
else:
with suppress(KeyError):
# In case previously triggered with --on-resume.
self.tasks_to_trigger_on_resume.remove(itask)
self.tasks_to_trigger_now.add(itask)
# In case previously triggered with --on-resume.

Check warning on line 2180 in cylc/flow/task_pool.py

View check run for this annotation

Codecov / codecov/patch

cylc/flow/task_pool.py#L2180

Added line #L2180 was not covered by tests
self.tasks_to_trigger_on_resume.discard(itask)

# Task may be set running before xtrigger is satisfied,
# if so check/spawn if xtrigger sequential.
Expand Down

0 comments on commit bd0e7ca

Please sign in to comment.