diff --git a/python/valuecell/server/api/routers/agent_stream.py b/python/valuecell/server/api/routers/agent_stream.py index 52210afad..b9295fdff 100644 --- a/python/valuecell/server/api/routers/agent_stream.py +++ b/python/valuecell/server/api/routers/agent_stream.py @@ -31,12 +31,7 @@ async def generate_stream(): query=request.query, agent_name=request.agent_name ): # Format as SSE (Server-Sent Events) - data = json.dumps({"content": chunk, "is_final": False}) - yield f"data: {data}\n\n" - - # Send final chunk - final_data = json.dumps({"content": "", "is_final": True}) - yield f"data: {final_data}\n\n" + yield f"data: {json.dumps(chunk)}\n\n" return StreamingResponse( generate_stream(),