improved errors

Author: sanderegg

services/director-v2/src/simcore_service_director_v2/core/errors.py

@@ -1,4 +1,4 @@
-""" Defines the different exceptions that may arise in the director
+"""Defines the different exceptions that may arise in the director
 
 
 TODO: Exceptions should provide all info to create Error instances of the API model
@@ -88,13 +88,14 @@ def __init__(self, project_id: ProjectID, node_id: NodeID, **ctx: Any) -> None:
 
     def get_errors(self) -> list[ErrorDict]:
         # default implementation
+
         return [
             {
                 "loc": (
                     f"{self.project_id}",
                     f"{self.node_id}",
                 ),
-                "msg": f"{self.args[0]}",
+                "msg": f"{self}",
                 "type": self.code,
             },
         ]

services/director-v2/src/simcore_service_director_v2/utils/dask.py

@@ -34,6 +34,7 @@
     NodeportsException,
     S3InvalidPathError,
     StorageInvalidCall,
+    UnboundPortError,
 )
 from simcore_sdk.node_ports_v2 import FileLinkType, Port, links, port_utils
 from simcore_sdk.node_ports_v2.links import ItemValue as _NPItemValue
@@ -147,6 +148,20 @@ async def parse_output_data(
             await (await ports.outputs)[port_key].set_value(value_to_transfer)
         except ValidationError as err:
             ports_errors.extend(_get_port_validation_errors(port_key, err))
+        except UnboundPortError as err:
+            ports_errors.extend(
+                [
+                    {
+                        "loc": (
+                            project_id,
+                            node_id,
+                            port_key,
+                        ),
+                        "msg": str(err),
+                        "type": "unbound_port",
+                    }
+                ]
+            )
 
     if ports_errors:
         raise PortsValidationError(