yumoqing/pipeline_core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: agent会话dspy加confirm事件处理分支(友好提示而非原始JSON)

Browse Source
This commit is contained in:
yumoqing 2026-08-16 18:52:52 +08:00
parent 085623f700
commit 6daac16190
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
wwwroot/api/agent_chat.dspy
View File

@ -100,6 +100,11 @@ if action == 'send_message':
yield json.dumps({"content": data.get('message', '')}, ensure_ascii=False) + '\n'
elif t == 'ask_user':
yield json.dumps({"content": "❓ " + data.get('message', '')}, ensure_ascii=False) + '\n'
elif t == 'confirm':
_tool = data.get('tool', '')
_params = data.get('params', {}) or {}
_cmd = _params.get('command', '') if isinstance(_params, dict) else ''
yield json.dumps({"content": "⚠️ 需要你确认执行命令：`" + str(_cmd)[:120] + "`\n请回复「确认」执行，或「取消」放弃。"}, ensure_ascii=False) + '\n'
elif t == 'error':
yield json.dumps({"error": data.get('message', '')}, ensure_ascii=False) + '\n'
else:

5
wwwroot/api/agent_chat_generic.dspy
View File

@ -38,6 +38,11 @@ if action == 'send_message':
yield json.dumps({"content": data.get('message', '')}, ensure_ascii=False) + '\n'
elif t == 'ask_user':
yield json.dumps({"content": "❓ " + data.get('message', '')}, ensure_ascii=False) + '\n'
elif t == 'confirm':
_tool = data.get('tool', '')
_params = data.get('params', {}) or {}
_cmd = _params.get('command', '') if isinstance(_params, dict) else ''
yield json.dumps({"content": "⚠️ 需要你确认执行命令：`" + str(_cmd)[:120] + "`\n请回复「确认」执行，或「取消」放弃。"}, ensure_ascii=False) + '\n'
elif t == 'error':
yield json.dumps({"error": data.get('message', '')}, ensure_ascii=False) + '\n'
else: