diff --git a/apps/application/flow/step_node/loop_node/impl/base_loop_node.py b/apps/application/flow/step_node/loop_node/impl/base_loop_node.py index 9d8d37f37a7..7ffbaf26d58 100644 --- a/apps/application/flow/step_node/loop_node/impl/base_loop_node.py +++ b/apps/application/flow/step_node/loop_node/impl/base_loop_node.py @@ -171,6 +171,8 @@ def loop(workflow_manage_new_instance, node: INode, generate_loop): 'child_node': child_node} content_chunk = (chunk.get('content', '') or '') reasoning_content_chunk = (chunk.get('reasoning_content', '') or '') + if chunk.get('real_node_id'): + chunk['real_node_id'] = chunk['real_node_id'] + '__' + str(index) reasoning_content += reasoning_content_chunk answer += content_chunk yield chunk