fix: use json.dumps instead of g.json.dumps

This commit is contained in:
ymq 2026-08-10 11:13:23 +08:00
parent c071ac19e2
commit 5936c7f59d

View File

@ -6,11 +6,11 @@ prompt = (params_kw or {}).get('prompt', '').strip()
if not prompt: if not prompt:
prompt = (params_kw or {}).get('message_text', '').strip() prompt = (params_kw or {}).get('message_text', '').strip()
if not prompt: if not prompt:
return g.json.dumps({"error": "缺少 prompt"}, ensure_ascii=False) return json.dumps({"error": "缺少 prompt"}, ensure_ascii=False)
uid = await get_user() uid = await get_user()
if not uid: if not uid:
return g.json.dumps({"error": "请先登录"}, ensure_ascii=False) return json.dumps({"error": "请先登录"}, ensure_ascii=False)
# 加载 v2 配置和执行引擎 # 加载 v2 配置和执行引擎
from pipeline_core.agent_config import load_agent_config, SDLC_DEFAULT_CONFIG from pipeline_core.agent_config import load_agent_config, SDLC_DEFAULT_CONFIG
@ -35,7 +35,7 @@ executor = AgentExecutor(
) )
async def agent_stream(): async def agent_stream():
d = g.json.dumps({"type": "progress", "message": f"Agent v2 处理中... (max_turns={config.max_turns})"}, ensure_ascii=False) + '\n' d = json.dumps({"type": "progress", "message": "Agent v2 ... (max_turns=" + str(config.max_turns) + ")"}, ensure_ascii=False) + '\n'
yield d yield d
async for chunk in executor.run(prompt): async for chunk in executor.run(prompt):