Skip to content

Commit

Permalink
expand submission paths correctly
Browse files Browse the repository at this point in the history
  • Loading branch information
nsheff committed Aug 15, 2023
1 parent f3c6ff9 commit 4d852e8
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions looper/conductor.py
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@
from pipestat import PipestatError
from ubiquerg import expandpath, is_command_callable
from yaml import dump
from yacman import YAMLConfigManager, expandpath as expath
from yacman import YAMLConfigManager

from .const import *
from .exceptions import JobSubmissionException, SampleFailedException
Expand Down Expand Up @@ -731,7 +731,7 @@ def write_script(self, pool, size):

namespaces["pipeline"]["var_templates"] = pl_iface[VAR_TEMPL_KEY] or {}
for k, v in namespaces["pipeline"]["var_templates"].items():
namespaces["pipeline"]["var_templates"][k] = expath(v)
namespaces["pipeline"]["var_templates"][k] = expandpath(v)

# pre_submit hook namespace updates
namespaces = _exec_pre_submit(pl_iface, namespaces)
Expand Down Expand Up @@ -766,7 +766,7 @@ def write_script(self, pool, size):
_LOGGER.debug("compute namespace:\n{}".format(self.prj.dcc.compute))
_LOGGER.debug("looper namespace:\n{}".format(looper))
_LOGGER.debug("pipestat namespace:\n{}".format(pipestat_namespace))
subm_base = os.path.join(self.prj.submission_folder, looper[JOB_NAME_KEY])
subm_base = os.path.join(expandpath(self.prj.submission_folder), looper[JOB_NAME_KEY])
return self.prj.dcc.write_script(
output_path=subm_base + ".sub", extra_vars=[{"looper": looper}]
)
Expand Down

0 comments on commit 4d852e8

Please sign in to comment.