diff --git a/apps/application/flow/workflow_manage.py b/apps/application/flow/workflow_manage.py
index 66e67a0824d..496b1847a78 100644
--- a/apps/application/flow/workflow_manage.py
+++ b/apps/application/flow/workflow_manage.py
@@ -679,7 +679,7 @@ def get_next_node_list(self, current_node, current_node_result):
                                 self.get_node_cls_by_id(edge.targetNodeId, self.get_up_node_id_list(edge.targetNodeId)))
                     else:
                         node_list.append(
-                            self.get_node_cls_by_id(edge.targetNodeId, self.get_up_node_id_list(edge.targetNodeId)))
+                            self.get_node_cls_by_id(edge.targetNodeId, [current_node.node.id]))
         return node_list
 
     def get_reference_field(self, node_id: str, fields: List[str]):