插话还是追问，不看消息看worker消费时在干什么

是什么

系列第 2 集：作者在自研事件驱动 Agent 上补齐 followup（追问）与 steering（插话）能力，属工程实现演示，非论文或开源项目发布。

关键内容

• 诊断 stage1 三处硬伤：publish 一路 await 到 handler（投递与执行绑死）、命令与事件语义混杂、单 task 串行无收件箱。
• 改造：总线一分为二——inbound 同步 publish 登记投递函数即返回、outbound 异步 emit 扇出；每 session 一条 asyncio 队列作收件箱，enqueue 用 put_nowait 且无 await 点；常驻 worker 只响应显式 stop。
• 核心论点：消息是插话还是追问不取决于内容，取决于消费时 worker 状态——空闲则开新 turn（followup），turn 运行中在 step 边界 drain 收件箱拼入当前上下文（steering）；turn_ended 升级为真事件，demo 借 tool_call_started 事件卡插话时机。

可借鉴

命令/事件分道、按 session 收件箱、按消费语境而非消息内容分类、worker 生命周期显式化，均可迁移到自建 agent runtime。

边界与风险

steering 仅在 step 边界生效，loop 运行中插入消息可能等 10 多秒；错过最后一个 drain 点会自然降级为 followup；打断与原地转向留待 stage3，目前无控制通道，仍是单 worker 串行方案。