Skip to content

Commit 6d80f02

Browse files
committed
add psij worker - 2
1 parent 71d0744 commit 6d80f02

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

pydra/engine/workers.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -904,14 +904,14 @@ def __init__(self, **kwargs):
904904
def run_el(self, interface, rerun=False, **kwargs):
905905
"""Run a task."""
906906
return self.exec_psij(interface, rerun=rerun)
907-
907+
908908
def make_spec(self, cmd=None, arg=None, cache_dir=None):
909909
spec = self.psij.JobSpec()
910910
spec.executable = cmd
911911
spec.arguments = arg
912912
spec.stdout_path = 'demo.stdout'
913913
spec.stderr_path = 'demo.stderr'
914-
914+
915915
return spec
916916

917917
def make_job(self, spec, attributes):
@@ -926,12 +926,12 @@ async def exec_psij(self, runnable, rerun=False):
926926
spec = self.make_spec(runnable.inputs.executable, runnable.inputs.args, runnable.cache_dir)
927927
job = self.make_job(spec, None)
928928
jex.submit(job)
929-
return
929+
return
930930

931931
def close(self):
932932
"""Finalize the internal pool of tasks."""
933933
pass
934-
934+
935935
WORKERS = {
936936
"serial": SerialWorker,
937937
"cf": ConcurrentFuturesWorker,

0 commit comments

Comments
 (0)