From 495a215084da82ab1964f08d5af18df75d05e78f Mon Sep 17 00:00:00 2001 From: Wenjie Zhang Date: Wed, 7 Jan 2026 11:19:12 +0800 Subject: [PATCH] =?UTF-8?q?refactor(knowledge=5Frouter):=20=E5=9C=A8?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E5=90=8D=E7=A7=B0=E4=B8=AD=E6=98=BE=E7=A4=BA?= =?UTF-8?q?=E7=9F=A5=E8=AF=86=E5=BA=93=E5=90=8D=E7=A7=B0=E8=80=8C=E9=9D=9E?= =?UTF-8?q?ID?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 获取知识库信息并显示名称，提升任务可读性 --- server/routers/knowledge_router.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/server/routers/knowledge_router.py b/server/routers/knowledge_router.py index 262944e7..e235d6d5 100644 --- a/server/routers/knowledge_router.py +++ b/server/routers/knowledge_router.py @@ -364,8 +364,9 @@ async def add_documents( return summary | {"items": processed_items} try: + database = knowledge_base.get_database_info(db_id) task = await tasker.enqueue( - name=f"知识库文档处理({db_id})", + name=f"知识库文档处理 ({database['name']})", task_type="knowledge_ingest", payload={ "db_id": db_id, @@ -421,8 +422,9 @@ async def parse_documents(db_id: str, file_ids: list[str] = Body(...), current_u return {"items": processed_items} try: + database = knowledge_base.get_database_info(db_id) task = await tasker.enqueue( - name=f"文档解析({db_id})", + name=f"文档解析 ({database['name']})", task_type="knowledge_parse", payload={"db_id": db_id, "file_ids": file_ids}, coroutine=run_parse, @@ -499,8 +501,9 @@ async def index_documents( return {"items": processed_items} try: + database = knowledge_base.get_database_info(db_id) task = await tasker.enqueue( - name=f"文档入库({db_id})", + name=f"文档入库 ({database['name']})", task_type="knowledge_index", payload={"db_id": db_id, "file_ids": file_ids, "params": params}, coroutine=run_index,