perf(chat): 使用asyncio.create_task优化异步任务处理

2025-10-03 01:55:21 +08:00
parent 06484245e1
commit a853722212
1 changed files with 1 additions and 1 deletions
--- a/src/chat/message_manager/distribution_manager.py
+++ b/src/chat/message_manager/distribution_manager.py
@@ -387,7 +387,7 @@ class StreamLoopManager:
            start_time = time.time()

            # 直接调用chatter_manager处理流上下文
-            results = await self.chatter_manager.process_stream_context(stream_id, context)
+            results = await asyncio.create_task(self.chatter_manager.process_stream_context(stream_id, context))
            success = results.get("success", False)

            if success: