Skip to main content

Module execution_loop

Module execution_loop 

Source
Expand description

Graph 流式执行循环 — SimpleExecutor::execute_stream() 的核心逻辑。

包含:

  • 执行循环(节点调度、路由、Mutation 消费)
  • GraphComplete / GraphError 事件发射
  • Checkpoint Save Path(根据 CheckpointPolicy 触发)

Barrier 等待与决策应用见 [barrier_wait] 模块。 Checkpoint Restore 路径留给 v0.5。

v0.4+: 泛型化 run_execution_loop<S, M>,支持任意 WorkflowState

Structs§

CheckpointConfig
Checkpoint 保存配置 — 三层策略。