一次 run 的内部管线:claim→open→切片→落库→deliver 回路

一次 run 的内部管线:claim→open→切片→落库→deliver 回路 由 Archify 生成的工作流图。 01 / 宿主调用面 Host API 02 / AgentHarness 外循环 · ExecutionAdapter EX / CommandGateway + Store 接收与认领 有界切片 落库与出口 每切片一个真实 AdapterSession Host / Worker · run/resume/deliver 入口 · 宿主调用面 Host API › 接收与认领 Host / Worker run/resume/deliver 入口 deliver(waitId,input) · →applyDelivery 原子写 · 宿主调用面 Host API › 接收与认领 deliver(waitId,input) →applyDelivery 原子写 HarnessRunResult · CONTINUE/WAIT/终态 · 宿主调用面 Host API › 落库与出口 HarnessRunResult CONTINUE/WAIT/终态 claimExecution · 租约+fencingToken · AgentHarness 外循环 · ExecutionAdapter › 接收与认领 · lease claimExecution 租约+fencingToken lease adapter.open · ctx+budget+prevState · AgentHarness 外循环 · ExecutionAdapter › 每切片一个真实 AdapterSession › 有界切片 adapter.open ctx+budget+prevState session.run · 每切片一 session · AgentHarness 外循环 · ExecutionAdapter › 每切片一个真实 AdapterSession › 有界切片 · bounded session.run 每切片一 session bounded snapshot() · 导出可序列化状态 · AgentHarness 外循环 · ExecutionAdapter › 每切片一个真实 AdapterSession › 有界切片 snapshot() 导出可序列化状态 结果映射 · CONTINUE/WAIT/终态 · AgentHarness 外循环 · ExecutionAdapter › 落库与出口 结果映射 CONTINUE/WAIT/终态 ensureWait · WaitRecord+Wakeup · CommandGateway + Store › 有界切片 ensureWait WaitRecord+Wakeup persistOutcome · outcome+checkpoint+event · CommandGateway + Store › 落库与出口 persistOutcome outcome+checkpoint+event answer+wakeup→READY deliver 唤醒等待 完成/失败 waitId/HostInput/Approval run(request)/resume(execId) WAITING 返回 图例 Agent 逻辑 策略 上下文 / 追踪 外部系统

有界切片

  • • 每次 run 只跑一段受 HarnessRunBudget 约束的切片:open 建真实 session、跑 ReAct/工具、snapshot 导出状态
  • • claim 生成租约+fencingToken;持久化校验 fencing 拒绝陈旧 worker 的迟到写入

deliver 回路

  • • 切片返回 waitId 或抛 HostInput/ApprovalRequired → ensureWait 落 WaitRecord+Wakeup,执行转 WAITING
  • • deliver(waitId,input) 原子写 answer+wakeup 转 READY;下一切片从 prevState+answer 恢复续跑