x
This commit is contained in:
+4
-1
@@ -110,7 +110,9 @@ async def get_status(task_id: str, db_session: AsyncSession = Depends(get_db_ses
|
||||
# 1. 内存任务(进行中的任务)
|
||||
if task_id in tasks:
|
||||
task = tasks[task_id]
|
||||
logger.info(f"返回内存任务状态:{task_id} - {task['status']} - geometry_data: {task.get('geometry_data', 'None')}")
|
||||
logger.info(f"返回内存任务状态:{task_id} - {task['status']}")
|
||||
logger.info(f"内存任务 analysis_result: {task.get('analysis_result', 'None')}")
|
||||
logger.info(f"内存任务 html_file: {task.get('html_file', 'None')}")
|
||||
return task
|
||||
|
||||
# 2. 持久化任务(已完成/失败,或服务重启后的任务)
|
||||
@@ -691,6 +693,7 @@ async def process_file_core(
|
||||
tasks[task_id]["analysis_result"] = analysis_result
|
||||
tasks[task_id]["cavity_data"] = detailed_cavity_json
|
||||
tasks[task_id]["key_info"] = detailed_cavity_json # 传递完整数据给前端
|
||||
tasks[task_id]["html_file"] = f"/html/{Path(html_file_path).name}" # 只使用文件名
|
||||
tasks[task_id]["status"] = ProcessingStatus.COMPLETED
|
||||
tasks[task_id]["completed_at"] = str(datetime.now())
|
||||
|
||||
|
||||
Reference in New Issue
Block a user