Skip to content

Commit

Permalink
task job mgr: use broadcast_mgr.get_updated_rtconfig interface
Browse files Browse the repository at this point in the history
* Spotted whilst reviewing cylc#6330
* Replace duplicated logic with a centralised implementation.
  • Loading branch information
oliver-sanders committed Sep 3, 2024
1 parent 9db2ca3 commit 17e5a6d
Showing 1 changed file with 2 additions and 11 deletions.
13 changes: 2 additions & 11 deletions cylc/flow/task_job_mgr.py
Original file line number Diff line number Diff line change
Expand Up @@ -51,10 +51,6 @@
is_remote_platform
)
from cylc.flow.job_file import JobFileWriter
from cylc.flow.parsec.util import (
pdeepcopy,
poverride
)
from cylc.flow.pathutil import get_remote_workflow_run_job_dir
from cylc.flow.platforms import (
get_host_from_platform,
Expand Down Expand Up @@ -1116,14 +1112,9 @@ def _prep_submit_task_job(
return itask

# Handle broadcasts
overrides = self.task_events_mgr.broadcast_mgr.get_broadcast(
itask.tokens
rtconfig = self.task_events_mgr.broadcast_mgr.get_updated_rtconfig(
itask
)
if overrides:
rtconfig = pdeepcopy(itask.tdef.rtconfig)
poverride(rtconfig, overrides, prepend=True)
else:
rtconfig = itask.tdef.rtconfig

# BACK COMPAT: host logic
# Determine task host or platform now, just before job submission,
Expand Down

0 comments on commit 17e5a6d

Please sign in to comment.