fixed up error message

Author: tclose

pydra/engine/specs.py

@@ -828,11 +828,16 @@ def _from_task(cls, task: "Task[WorkflowDef]") -> Self:
             for node in errored:
                 for node_task in node.errored.values():
                     result = node_task.result()
+                    if result.errors:
+                        time_of_crash = result.errors["time of crash"]
+                        error_message = "\n".join(result.errors["error message"])
+                    else:
+                        time_of_crash = "UNKNOWN-TIME"
+                        error_message = "NOT RETRIEVED"
                     errors.append(
-                        f"Node {node.name!r} failed @ {result.errors['time of crash']} "
-                        f"running {node._definition} with the following errors:\n"
-                        + "\n".join(result.errors["error message"])
-                        + "To inspect, please load the pickled task object from here: "
+                        f"Task {node.name!r} failed @ {time_of_crash} "
+                        f"running {node._definition} with the following errors:\n{error_message}"
+                        "To inspect, please load the pickled task object from here: "
                         f"{result.output_dir}/_task.pklz"
                     )
             raise RuntimeError(

pydra/engine/tests/test_task.py

@@ -1360,7 +1360,7 @@ def Workflow(x_list):
         return fun_error.out
 
     wf = Workflow(x_list=[3, 4])
-    with pytest.raises(RuntimeError, match="Node 'fun_error' failed.*") as exinfo:
+    with pytest.raises(RuntimeError, match="Task 'fun_error' failed.*") as exinfo:
         with Submitter(worker="cf", cache_dir=tmpdir) as sub:
             sub(wf, raise_errors=True)