debugged error rerun

Author: tclose

pydra/engine/submitter.py

@@ -417,7 +417,7 @@ async def expand_workflow_async(
                             )
                         raise RuntimeError(msg)
             for task in tasks:
-                if task.is_async:
+                if task.is_async:  # Only workflows at this stage
                     await self.worker.run_async(
                         task, rerun=rerun and self.propagate_rerun
                     )

pydra/engine/tests/test_workflow.py

@@ -4480,10 +4480,10 @@ class EvenException(Exception):
     @python.define
     def PassOdds(x):
         if x % 2 == 0:
-            print(f"x%2 = {x % 2} (error)\n")
+            print(f"x={x}, x%2 = {x % 2} (error)\n")
             raise EvenException("even error")
         else:
-            print(f"x%2 = {x % 2}\n")
+            print(f"x={x}, x%2 = {x % 2}\n")
             return x
 
     @workflow.define
@@ -4493,9 +4493,12 @@ def Worky(x):
 
     worky = Worky(x=[1, 2, 3, 4, 5])
 
+    print("Starting run 1")
     with pytest.raises(RuntimeError):
         # Must be cf to get the error from all tasks, otherwise will only get the first error
         worky(worker="cf", cache_dir=tmp_path, n_procs=5)
+
+    print("Starting run 2")
     with pytest.raises(RuntimeError):
         worky(worker="cf", cache_dir=tmp_path, n_procs=5)