[Bug]: 调用机器人，偶现没有消息回复，原因排查！

[Alex-wwei]

Runtime environment

docker启动

Exception

[12-05 14:43:41.640] pipelinemgr.py (253) - [ERROR] : Error processing query 99 stage=MessageProcessor : list index out of range
[12-05 14:43:41.641] pipelinemgr.py (254) - [ERROR] : Traceback: Traceback (most recent call last):
File "/app/src/langbot/pkg/pipeline/pipelinemgr.py", line 250, in process_query
await self._execute_from_stage(0, query)
File "/app/src/langbot/pkg/pipeline/pipelinemgr.py", line 210, in _execute_from_stage
await self._check_output(query, sub_result)
File "/app/src/langbot/pkg/pipeline/pipelinemgr.py", line 137, in _check_output
bot_message=query.resp_messages[-1],
~~~~~~~~~~~~~~~~~~~^^^^
IndexError: list index out of range

Reproduction steps

创建一个钉钉adapter机器人，关闭开启机器人数次，即使前端显示关闭成功，但后台并没有真正关闭掉钉钉的进程。这样钉钉发送的消息会偶尔推送到之前未关闭的ws连接处理，导致无消息结果返回。

Enabled plugins

No response

[dosubot]

Hi @Alex-wwei! I'm Dosu and I’m helping the LangBot team.

这个问题的根本原因是钉钉 adapter 没有在重启或关闭时清理旧的 WebSocket 连接，导致钉钉服务端偶尔会把消息推送到之前未关闭的连接上。这样 pipeline 在处理这些“僵尸”连接收到的消息时，往往没有生成 resp_messages，直接访问 query.resp_messages[-1] 就会抛出 IndexError（list index out of range）相关代码分析。

目前代码没有实现 WebSocket 的关闭或清理逻辑，kill 方法只是个空实现，run_async 只负责启动连接，导致容器重启后旧连接还在，钉钉消息会被推送到多个会话，出现偶现无回复和异常 代码细节。

临时规避建议：

• 重启前务必彻底停止并移除旧容器，确保没有遗留的 WebSocket 连接。
• 监控钉钉后台，避免同一个机器人有多个活跃连接。
• 建议在 pipelinemgr.py 访问 resp_messages[-1] 前加非空判断，防止 IndexError。

长期建议：

• adapter 层需要补充 WebSocket 连接的关闭和清理逻辑，确保生命周期管理健壮，避免僵尸连接。
• 关注相关 PR（如 fix: dingtalk & wecom problems #1424）和后续修复进展。

如需代码层面修改建议或具体实现思路，可以继续交流。

To reply, just mention @dosu.

---

^{How did I do? Good | Irrelevant | Incorrect | Verbose | Hallucination | Report 🐛 | Other}

  

[Alex-wwei]

究其原因，经过源码分析，在调用机器人关闭的操作时并没有彻底关掉之前和钉钉建立的WS链接，因为dingtalk_stream框架没有友好的关闭ws的方法，本人也尝试数次改源码未能解决此问题，希望大佬们看到尽快解决下。这个场景太常见了。