hansjone/oclaw
1
0
Fork 0
mirror of https://github.com/hansjone/oclaw.git synced 2026-10-14 05:33:18 +08:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

fix bubble splitting after session interruption

Browse source
This commit is contained in:
oliver 2026-07-23 09:48:51 +08:00
parent 896126ef88
commit 23ecce4755
2 changed files with 8 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

8
docs/ip-knowledge-base/zte/06_标准SOP与工具脚本/故障处理常用命令.md
View file

@ -1,7 +1,7 @@
# 故障处理常用命令目录集（ZTE ZXROS） # 故障处理常用命令目录集（ZTE ZXROS）
> **设备**：MER1 @ 10.229.234.136 (ZXCTN 9000-3EA, V5.00.10.70) > **设备**：MER1 @ 10.229.234.136 (ZXCTN 9000-3EA, V5.00.10.70)
> **更新时间**：2026-07-20 > **更新时间**：2026-07-22
> **验证状态**：✅ 已验证 / ❌ 错误命令（已删除） > **验证状态**：✅ 已验证 / ❌ 错误命令（已删除）
--- ---
@ -12,6 +12,8 @@
```bash ```bash
show bgp ipv4 unicast # BGP IPv4单播路由表 show bgp ipv4 unicast # BGP IPv4单播路由表
show bgp ipv4 unicast summary # BGP IPv4摘要信息 show bgp ipv4 unicast summary # BGP IPv4摘要信息
show bgp ipv4 unicast neighbor # BGP IPv4邻居信息
show bgp ipv4 unicast neighbor <ip-address> # 指定邻居的详细信息
``` ```
### 1.2 BGP VPNv4 ### 1.2 BGP VPNv4
@ -240,6 +242,6 @@ netx平台限制了管道符等特殊字符的使用，建议分步执行命令
--- ---
**文档维护**： **文档维护**：
- 最后更新：2026-07-20 - 最后更新：2026-07-22
- 验证设备：MER1 @ 10.229.234.136 - 验证设备：MER1 @ 10.229.234.136
- 关联文档：`命令探索方法论.md`、`BGP跨域排障命令速查.md` - 关联文档：`命令探索方法论.md`、`BGP跨域排障命令速查.md`

5
interfaces/ws/turn_runner.py
View file

@ -582,7 +582,7 @@ async def run_agent_turn_via_bridge(
final_text = "".join(token_chunks) final_text = "".join(token_chunks)
stream_snapshot = str(final_text or "").strip() stream_snapshot = str(final_text or "").strip()
turn_for_persist = str(getattr(result, "turn_uuid", "") or "").strip() turn_for_persist = str(getattr(result, "turn_uuid", "") or "").strip()
final_msg: dict[str, Any] = {"role": "assistant", "content": final_text, "timestamp": now_ms()} final_msg: dict[str, Any] = {"role": "assistant", "content": final_text, "timestamp": now_ms(), "turn_uuid": turn_for_persist or ""}
if run_status == "failed" and not stream_snapshot: if run_status == "failed" and not stream_snapshot:
err_code = run_last_error_code or "unknown_error" err_code = run_last_error_code or "unknown_error"
stop_reason = run_stop_reason or "failed" stop_reason = run_stop_reason or "failed"
@ -594,7 +594,7 @@ async def run_agent_turn_via_bridge(
f"{detail_line}" f"{detail_line}"
"\n\n请重试，或减少输入复杂度后再试。" "\n\n请重试，或减少输入复杂度后再试。"
) )
final_msg = {"role": "assistant", "content": final_text, "timestamp": now_ms()} final_msg = {"role": "assistant", "content": final_text, "timestamp": now_ms(), "turn_uuid": turn_for_persist or ""}
try: try:
store.add_message( store.add_message(
session_id=str(session_id), session_id=str(session_id),
@ -641,6 +641,7 @@ async def run_agent_turn_via_bridge(
"timestamp": str(getattr(m, "timestamp", "") or ""), "timestamp": str(getattr(m, "timestamp", "") or ""),
"tool_calls": getattr(m, "tool_calls", None), "tool_calls": getattr(m, "tool_calls", None),
"attachments": atraw, "attachments": atraw,
"turn_uuid": str(getattr(m, "turn_uuid", "") or "").strip(),
} }
# Admin / WS clients build the reasoning fold from event_payload.reasoning_content (thinking mode) # Admin / WS clients build the reasoning fold from event_payload.reasoning_content (thinking mode)
# or event_type=reasoning rows after reload; including these on ``final`` avoids "stream had # or event_type=reasoning rows after reload; including these on ``final`` avoids "stream had