平行分支

多分支并行也是我们在开发编排中常见的诉求， Agently Workflow 支持您使用以下方式轻松编排不同种类的多分支并行。

从单一起点工作块发散的多分支并行

# 通常包含多分支的工作流不追求在一段链式表达中完成
# 需要分成多段表达

# 第一段：START->分支起始点
workflow.connect_to("start_chunk")

# 第二段：分支起始点->A分支
(
    workflow.chunks["start_chunk"]
        .connect_to("branch_a_chunk_1")
        .connect_to("branch_a_chunk_2")
)

# 第三段：分支起始点->B分支
(
    workflow.chunks["start_chunk"]
        .connect_to("branch_b_chunk_1")
        .connect_to("branch_b_chunk_2")
)

从单一起点工作块发散，并最终需要在同一个结束工作块等待多个并行分支完成

# 第一段：START->分支起始点
workflow.connect_to("start_chunk")

# 第二段：分支起始点->A分支->结束块
(
    workflow.chunks["start_chunk"]
        .connect_to("branch_a_chunk_1")
        .connect_to("branch_a_chunk_2")
        # 使用不同的输入端点承接分支运行结果
        .connect_to("end_chunk.branch_a")
)

# 第三段：分支起始点->B分支->结束块
(
    workflow.chunks["start_chunk"]
        .connect_to("branch_b_chunk_1")
        .connect_to("branch_b_chunk_2")
        # 使用不同的输入端点承接分支运行结果
        .connect_to("end_chunk.branch_b")
)

关于工作块端点和输入端点的运行逻辑，更详细说明请点击查看这里

更复杂的分支组合编排

# 第一段：START->分支起始点
workflow.connect_to("start_chunk")

# 第二段：分支起始点->A分支->第一等待块
(
    workflow.chunks["start_chunk"]
        .connect_to("branch_a_chunk_1")
        .connect_to("branch_a_chunk_2")
        # 使用不同的输入端点承接分支运行结果
        .connect_to("first_wait_chunk.branch_a")
)

# 第三段：分支起始点->B分支->第一等待块
(
    workflow.chunks["start_chunk"]
        .connect_to("branch_b_chunk_1")
        .connect_to("branch_b_chunk_2")
        # 使用不同的输入端点承接分支运行结果
        .connect_to("first_wait_chunk.branch_b")
)

# 第四段：分支起始点->C分支->第二等待块
(
    workflow.chunks["start_chunk"]
        .connect_to("branch_c_chunk_1")
        .connect_to("branch_c_chunk_2")
        # 因为只有一个下游等待块，可以直接使用默认的输入端点
        .connect_to("second_wait_chunk")
)

# 第五段：第一等待块/第二等待块->结束块
workflow.chunks["first_wait_chunk"].connect_to("end_chunk.first")
workflow.chunks["second_wait_chunk"].connect_to("end_chunk.second")