kris/ForcePilot
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

style: auto-format with ruff [skip ci]

Browse Source
This commit is contained in:
GitHub Actions 2026-01-12 11:23:49 +00:00
parent 5a5b105769
commit 02334bca38
1 changed files with 12 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
server/routers/knowledge_router.py
View File

@ -223,7 +223,7 @@ async def add_documents(
indexing_params = { indexing_params = {
"chunk_size": params.get("chunk_size", 1000), "chunk_size": params.get("chunk_size", 1000),
"chunk_overlap": params.get("chunk_overlap", 200), "chunk_overlap": params.get("chunk_overlap", 200),
"qa_separator": params.get("qa_separator", "") "qa_separator": params.get("qa_separator", ""),
} }
# 禁止 URL 解析与入库 # 禁止 URL 解析与入库
@ -326,18 +326,22 @@ async def add_documents(
try: try:
# 1. 更新入库参数 # 1. 更新入库参数
await knowledge_base.update_file_params(db_id, file_id, indexing_params, operator_id=current_user.id) await knowledge_base.update_file_params(
db_id, file_id, indexing_params, operator_id=current_user.id
)
# 2. 执行入库 # 2. 执行入库
result = await knowledge_base.index_file(db_id, file_id, operator_id=current_user.id) result = await knowledge_base.index_file(db_id, file_id, operator_id=current_user.id)
processed_items.append(result) processed_items.append(result)
except Exception as index_error: except Exception as index_error:
logger.error(f"自动入库失败 {item} (file_id={file_id}): {index_error}") logger.error(f"自动入库失败 {item} (file_id={file_id}): {index_error}")
processed_items.append({ processed_items.append(
"item": item, {
"status": "failed", "item": item,
"error": f"入库失败: {str(index_error)}", "status": "failed",
"error_type": "index_failed", "error": f"入库失败: {str(index_error)}",
}) "error_type": "index_failed",
}
)
except asyncio.CancelledError: except asyncio.CancelledError:
await context.set_progress(100.0, "任务已取消") await context.set_progress(100.0, "任务已取消")