refactor: Refactors error handling in WorkflowNodeRunFailedError

Signed-off-by: -LAN- <laipz8200@outlook.com>

api/core/workflow/errors.py

@@ -2,7 +2,7 @@ from core.workflow.nodes.base import BaseNode
 
 
 class WorkflowNodeRunFailedError(Exception):
-    def __init__(self, node: BaseNode, error: str):
-        self.node = node
-        self.error = error
-        super().__init__(f"Node {node.title} run failed: {error}")
+    def __init__(self, node: BaseNode, err_msg: str):
+        self._node = node
+        self._error = err_msg
+        super().__init__(f"Node {node.title} run failed: {err_msg}")

api/core/workflow/workflow_entry.py

@@ -193,7 +193,7 @@ class WorkflowEntry:
             generator = node.run()
         except Exception as e:
             logger.exception(f"error while running node, {workflow.id=}, {node.id=}, {node.type_=}, {node.version()=}")
-            raise WorkflowNodeRunFailedError(node=node, error=str(e))
+            raise WorkflowNodeRunFailedError(node=node, err_msg=str(e))
         return node, generator
 
     @classmethod
@@ -296,7 +296,7 @@ class WorkflowEntry:
             return node, generator
         except Exception as e:
             logger.exception(f"error while running node, {node.id=}, {node.type_=}, {node.version()=}")
-            raise WorkflowNodeRunFailedError(node=node, error=str(e))
+            raise WorkflowNodeRunFailedError(node=node, err_msg=str(e))
 
     @staticmethod
     def handle_special_values(value: Optional[Mapping[str, Any]]) -> Mapping[str, Any] | None:

api/services/workflow_service.py

@@ -509,10 +509,10 @@ class WorkflowService:
             )
             error = node_run_result.error if not run_succeeded else None
         except WorkflowNodeRunFailedError as e:
-            node = e.node
+            node = e._node
             run_succeeded = False
             node_run_result = None
-            error = e.error
+            error = e._error
 
         # Create a NodeExecution domain model
         node_execution = WorkflowNodeExecution(