跳转至

Side Branch & ____

侧分支与分隔符示例。

源码

from agently import TriggerFlow, TriggerFlowEventData


## TriggerFlow Side Branch + ____ separator
def triggerflow_side_branch_demo():
    # Idea: run a side branch without blocking the main path.
    # Flow: main -> ____ separator -> side_branch -> end
    # Expect: prints side branch output and main result.
    flow = TriggerFlow()

    async def main_task(data: TriggerFlowEventData):
        return f"main: {data.value}"

    async def side_task(data: TriggerFlowEventData):
        print(f"[side] {data.value}")
        return "side done"

    (
        flow.to(main_task)
        .____(print_info=True, show_value=True)
        .side_branch(side_task)
        .to(lambda d: print("[main]", d.value))
        .end()
    )

    flow.start("hello")


# triggerflow_side_branch_demo()

讲解

  • 侧分支用于非阻塞任务。

注释解读

  • Idea 表示案例思路
  • Flow 表示执行编排路径
  • Expect 表示预期输出或行为

你学会了什么

  • 理解 side_branch 的非阻塞特性

练习任务

  • 增加一个 side_branch 做日志输出