diff --git a/server/routers/knowledge_router.py b/server/routers/knowledge_router.py index ee38257a..fc46d2e3 100644 --- a/server/routers/knowledge_router.py +++ b/server/routers/knowledge_router.py @@ -407,12 +407,14 @@ async def rechunks_documents( error_type = "timeout" if isinstance(doc_error, TimeoutError) else "processing_error" error_msg = "处理超时" if isinstance(doc_error, TimeoutError) else "处理失败" - processed_items.append({ - "file_id": file_id, - "status": "failed", - "error": f"{error_msg}: {str(doc_error)}", - "error_type": error_type - }) + processed_items.append( + { + "file_id": file_id, + "status": "failed", + "error": f"{error_msg}: {str(doc_error)}", + "error_type": error_type, + } + ) except asyncio.CancelledError: await context.set_progress(100.0, "任务已取消") @@ -422,13 +424,15 @@ async def rechunks_documents( logger.exception(f"Task rechunking failed: {task_error}") await context.set_progress(100.0, f"任务处理失败: {str(task_error)}") # 将所有未处理的文档标记为失败 - for file_id in file_ids[len(processed_items):]: - processed_items.append({ - "file_id": file_id, - "status": "failed", - "error": f"任务失败: {str(task_error)}", - "error_type": "task_failed" - }) + for file_id in file_ids[len(processed_items) :]: + processed_items.append( + { + "file_id": file_id, + "status": "failed", + "error": f"任务失败: {str(task_error)}", + "error_type": "task_failed", + } + ) raise failed_count = len([_p for _p in processed_items if _p.get("status") == "failed"]) diff --git a/src/knowledge/utils/__init__.py b/src/knowledge/utils/__init__.py index 0588c186..4863799a 100644 --- a/src/knowledge/utils/__init__.py +++ b/src/knowledge/utils/__init__.py @@ -21,5 +21,6 @@ __all__ = [ "prepare_item_metadata", "split_text_into_chunks", "split_text_into_qa_chunks", + "merge_processing_params", "validate_file_path", ] diff --git a/src/knowledge/utils/kb_utils.py b/src/knowledge/utils/kb_utils.py index 9942bde1..5ea50fd9 100644 --- a/src/knowledge/utils/kb_utils.py +++ b/src/knowledge/utils/kb_utils.py @@ -229,7 +229,7 @@ def merge_processing_params(metadata_params: dict | None, request_params: dict | if request_params: merged_params.update(request_params) - logger.debug(f"Merged processing params: metadata={metadata_params}, request={request_params}, result={merged_params}") + logger.debug(f"Merged processing params: {metadata_params=}, {request_params=}, {merged_params=}") return merged_params diff --git a/web/src/assets/css/base.css b/web/src/assets/css/base.css index 6b8d77fd..0b3d78cd 100644 --- a/web/src/assets/css/base.css +++ b/web/src/assets/css/base.css @@ -50,6 +50,7 @@ --color-success: #45b30e; --color-error: #c73234; --color-info: #0058d4; + --color-warning: #faad14; /* Chart Colors - 图表颜色系统 */ --chart-primary: var(--main-500); /* 主色调 - 用于主要数据 */ diff --git a/web/src/components/FileTable.vue b/web/src/components/FileTable.vue index 72d0c2fb..58fc753f 100644 --- a/web/src/components/FileTable.vue +++ b/web/src/components/FileTable.vue @@ -50,7 +50,7 @@