diff --git a/api/core/workflow/nodes/base/node.py b/api/core/workflow/nodes/base/node.py index ce089003cf..6f2a8fc2f3 100644 --- a/api/core/workflow/nodes/base/node.py +++ b/api/core/workflow/nodes/base/node.py @@ -144,6 +144,8 @@ class Node: elif isinstance(event, GraphNodeEventBase) and not event.in_iteration_id and not event.in_loop_id: # pyright: ignore[reportUnnecessaryIsInstance] event.id = self._node_execution_id yield event + else: + yield event except Exception as e: logger.exception("Node %s failed to run", self._node_id) result = NodeRunResult(