大模块流程
接口调用chat / cron / acceptance / skill admin
->
AgentService路由 simple vs Task
->
Task 编排planner、team、main run、evidence
->
状态落盘session events、task store、run memory、skill learning
小模块拆分
AgentService
核心服务。普通消息先由 MainAgentRouter 分类;simple chat 关闭 skill/tool 装配直接跑;Task 模式创建或复用 TaskRecord,计划 single/team,运行主 agent,记录 evidence,并等待用户验收。
输入 message + session kwargs,创建 provider bundle。
调用 Intent Agent,得到 simple_chat / continue_task / revise_task / new_task / close_task / abandon_task。
Task 模式中调用 TaskExecutionPlanner,必要时先跑 TeamGraphScheduler。
主 AgentLoop 执行后构建 evidence packet;evidence 只记录事实,不判断结果质量。
run 完成后进入 awaiting_acceptance;用户 accept/revise/abandon 决定后续状态。
Prompt 相关:AgentService 组装 Task skill selection context、team execution context、scheduled execution context,详细见 Prompt Atlas。
CronService
管理定时任务的创建、启停、触发、run history。CronService 负责调度状态;真正生成内容时调用 AgentService 的 scheduled task 或 notification 路径。
保存 CronJob 配置和 payload。
到点创建 CronRunRecord。
调用 AgentService 执行 notification 或 Task。
回写 output/error/task_id/run_id。
核对点:run_scheduled_task() 当前末尾引用未定义 job/run,应改为函数入参。
TeamService
提供 team graph 的产品级封装。底层执行在 coordinator,Service 层关心的是把执行结果转成 API 友好的结构。
接收 graph / nodes / strategy。
创建 TeamGraphScheduler 和 LocalAgentRunner。
返回 node results、run ids、success/error。
MemoryService 与 SessionProcessProjector
MemoryService 给每个 run 捕获 frozen curated memory snapshot;SessionProcessProjector 把 session 事件投影成 UI 所需的过程视图。
run 开始前捕获 memory snapshot,避免运行中写入导致 prompt 漂移。
session event 记录完整过程。
projector 从事件流还原步骤、工具、evidence 和用户验收状态。
SkillHubService
面向产品的 skill 草稿、审核、发布、学习候选接口。底层由 skills/drafts/reviews/publisher/learning 实现。
列出 learning candidates 或 drafts。
触发 draft synthesis / review。
人工确认后发布为 published skill。