auto-sync: 2026-05-17 13:06:33

2026-05-17 13:06:33 +08:00
parent a9b4708c9b
commit 1f7f554a0b
1 changed files with 2 additions and 3 deletions
@@ -98,14 +98,13 @@ async def update_status(project_id: str, task_id: str, body: Dict[str, Any]):
    try:
        from src.api.sse_routes import get_broker
        broker = get_broker()
-        broker.publish({
-            "type": "task_updated",
+        broker.publish_sync("task_updated", {
            "project_id": project_id,
            "task_id": task_id,
            "old_status": old_task.status if old_task else None,
            "new_status": body["status"],
            "agent": body.get("agent"),
-        }, event_type="task_updated")
+        })
    except Exception:
        pass  # SSE 是可选的，不影响主流程
    return {"ok": True}