Update app.py

app.py

@@ -219,6 +219,28 @@ async def create_task(prompt: str = Body(..., embed=True)):
 async def run_task(task_id: str, prompt: str):
     try:
         task_manager.tasks[task_id].status = "running"
+        logger.info("✨ Manus's thoughts: testing SSE event emission")
+
+         # Attach SSE logger
+        def make_sse_handler(task_id):
+            handler = SSELogHandler(task_id)
+
+            def sink(message):
+                asyncio.create_task(handler(str(message)))
+
+            return sink
+
+        logger.add(make_sse_handler(task_id))
+
+        # Simulate external call delay and emit result manually
+        await asyncio.sleep(2)
+        logger.info("🎉 Manus result: Hello from mock")
+
+        await task_manager.update_task_step(task_id, 1, "Hello from mock", "result")
+        await task_manager.complete_task(task_id)
+
+    except Exception as e:
+        await task_manager.fail_task(task_id, str(e))
 
         async def on_think(thought):
             await task_manager.update_task_step(task_id, 0, thought, "think")
@@ -271,16 +293,6 @@ async def run_task(task_id: str, prompt: str):
                     self.task_id, 0, cleaned_message, event_type
                 )
         
-        def make_sse_handler(task_id):
-            handler = SSELogHandler(task_id)
-
-            def sink(message):
-                asyncio.create_task(handler(str(message)))
-
-            return sink
-            
-        logger.add(make_sse_handler(task_id))
-
         import re
         def has_log_prefix(message):
             # 检查字符串是否包含两个 "|" 且以 " - " 分割前缀和内容