This commit is contained in:
Kevin Hu 2025-11-20 13:51:03 +08:00
parent bac1ac13b6
commit 4172d3acbe

View file

@ -162,7 +162,7 @@ async def webhook(tenant_id: str, agent_id: str):
def sse():
nonlocal canvas
try:
for ans in canvas.run(query=req.get("query", ""), files=req.get("files", []), user_id=req.get("user_id", tenant_id), webhook_payload=req):
async for ans in canvas.run(query=req.get("query", ""), files=req.get("files", []), user_id=req.get("user_id", tenant_id), webhook_payload=req):
yield "data:" + json.dumps(ans, ensure_ascii=False) + "\n\n"
cvs.dsl = json.loads(str(canvas))