From 80c7b02b36f0d2ecd3b142f7fc66e280ef2446b0 Mon Sep 17 00:00:00 2001 From: Ghislain Vaillant Date: Fri, 22 Mar 2024 10:31:45 +0100 Subject: [PATCH 1/2] BUG: Remove residual print statement in submitter --- pydra/engine/submitter.py | 1 - 1 file changed, 1 deletion(-) diff --git a/pydra/engine/submitter.py b/pydra/engine/submitter.py index cbb4064e7..fe3e598c2 100644 --- a/pydra/engine/submitter.py +++ b/pydra/engine/submitter.py @@ -90,7 +90,6 @@ async def submit_from_call(self, runnable, rerun, environment): # 2 if runnable.state is None: # run_el should always return a coroutine - print("in SUBM", environment) await self.worker.run_el(runnable, rerun=rerun, environment=environment) # 3 else: From 14d1e1907d57ba4156a6c0669e054946ace823a4 Mon Sep 17 00:00:00 2001 From: Ghislain Vaillant Date: Fri, 22 Mar 2024 10:39:40 +0100 Subject: [PATCH 2/2] BUG: Fix signature for _run_task --- pydra/engine/core.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pydra/engine/core.py b/pydra/engine/core.py index a523c2452..d0081e3ac 100644 --- a/pydra/engine/core.py +++ b/pydra/engine/core.py @@ -380,7 +380,7 @@ def can_resume(self): return self._can_resume @abc.abstractmethod - def _run_task(self): + def _run_task(self, environment=None): pass @property @@ -1329,7 +1329,7 @@ async def _run(self, submitter=None, rerun=False, **kwargs): self._check_for_hash_changes() return result - async def _run_task(self, submitter, rerun=False): + async def _run_task(self, submitter, rerun=False, environment=None): if not submitter: raise Exception("Submitter should already be set.") for nd in self.graph.nodes: