Skip to content

Commit aaa399f

Browse files
committed
adding environment to run_el for slurm worker
1 parent fa240d9 commit aaa399f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pydra/engine/workers.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -217,7 +217,7 @@ def __init__(self, loop=None, max_jobs=None, poll_delay=1, sbatch_args=None):
217217
self.sbatch_args = sbatch_args or ""
218218
self.error = {}
219219

220-
def run_el(self, runnable, rerun=False): # TODO: add env
220+
def run_el(self, runnable, rerun=False, environment=None):
221221
"""Worker submission API."""
222222
script_dir, batch_script = self._prepare_runscripts(runnable, rerun=rerun)
223223
if (script_dir / script_dir.parts[1]) == gettempdir():

0 commit comments

Comments
 (0)