From bfe2492c4a74b97873f8a7b8fa7f666988ea77b8 Mon Sep 17 00:00:00 2001 From: Tian jianyong <11429339@qq.com> Date: Wed, 24 Dec 2025 20:21:44 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=BC=82=E6=AD=A5=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../module_admin/controller/ragflow_controller.py | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/ruoyi-fastapi-backend/module_admin/controller/ragflow_controller.py b/ruoyi-fastapi-backend/module_admin/controller/ragflow_controller.py index eb8b012..36db12c 100644 --- a/ruoyi-fastapi-backend/module_admin/controller/ragflow_controller.py +++ b/ruoyi-fastapi-backend/module_admin/controller/ragflow_controller.py @@ -326,11 +326,8 @@ def stream_ragflow_response(result: Generator, chat_id: str, start_time: float, if cache_store_func and last_answer and len(last_answer.strip()) >= 10: try: import asyncio - cache_task = asyncio.create_task(cache_store_func(last_answer)) - cache_task.add_done_callback( - lambda t: logger.info(f'[RAG_CACHE] 缓存存储完成 | chat_id={chat_id} | answer_length={len(last_answer)}') - if not t.exception() else logger.warning(f'[RAG_CACHE] 缓存存储失败: {t.exception()}') - ) + asyncio.run(cache_store_func(last_answer)) + logger.info(f'[RAG_CACHE] 缓存存储完成 | chat_id={chat_id} | answer_length={len(last_answer)}') except Exception as cache_err: logger.warning(f'[RAG_CACHE] 缓存存储失败: {cache_err}')