barian0517/OpenManus
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

last try

Browse Source
This commit is contained in:
rxdaozhang 2025-03-11 02:36:50 +08:00
parent c37c6c19b5
commit d9418c1668
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app.py
View File

@ -172,7 +172,7 @@ async def task_events(task_id: str):
task = task_manager.tasks.get(task_id) task = task_manager.tasks.get(task_id)
if task: if task:
yield f"event: status\ndata: {dumps({'type': 'status','status': task.status,'steps': task.steps})}\n\n" yield f"event: status\ndata: {dumps({'type': 'status', 'status': task.status, 'steps': task.steps})}\n\n"
while True: while True:
try: try:
@ -190,7 +190,7 @@ async def task_events(task_id: str):
elif event["type"] == "step": elif event["type"] == "step":
task = task_manager.tasks.get(task_id) task = task_manager.tasks.get(task_id)
if task: if task:
yield f"event: status\ndata: {dumps({ 'type': 'status','status': task.status,'steps': task.steps })}\n\n" yield f"event: status\ndata: {dumps({'type': 'status', 'status': task.status, 'steps': task.steps})}\n\n"
yield f"event: {event['type']}\ndata: {formatted_event}\n\n" yield f"event: {event['type']}\ndata: {formatted_event}\n\n"
elif event["type"] in ["think", "tool", "act", "run"]: elif event["type"] in ["think", "tool", "act", "run"]:
yield f"event: {event['type']}\ndata: {formatted_event}\n\n" yield f"event: {event['type']}\ndata: {formatted_event}\n\n"
@ -244,4 +244,4 @@ async def generic_exception_handler(request: Request, exc: Exception):
if __name__ == "__main__": if __name__ == "__main__":
import uvicorn import uvicorn
uvicorn.run(app, host="localhost", port=5172) uvicorn.run(app, host="localhost", port=5172)