how to parallel execute dynamic node

[zhufeijuanjuan]

I am developing an agent using langgraph. After decomposing the target task, it may generate an uncertain number of subtasks. The first N subtasks can be executed in parallel. How can I achieve this using langgraph? Currently, I only know how to implement parallel execution with a fixed number of nodes. Thx in advance.

[zhufeijuanjuan]

i solved it.

def _create_agent_node(self, task_id):
    """基于task_id生成多个副本节点"""
    return partial(
        self._public_execute_step_node, task_id=task_id, prompt_builder=self.prompt_builder,
        agent_executor=self.agent_executor
    )

def subgraph_build(self, graph, task_num):
    """
    根据动态节点数量，动态构建节点和边
    :param graph:
    :param task_num:
    :return:
    """
    agent_name_list = []
    for i in range(task_num):
        agent_node = self._create_agent_node(task_id=i)
        graph.add_node(f"agent_{i}", agent_node)
        graph.add_edge(start_key=START, end_key=f"agent_{i}")
        agent_name_list.append(f"agent_{i}")
    graph.add_edge(start_key=agent_name_list, end_key=END)
    return graph