|
@@ -270,7 +270,7 @@ async def _process_ner_task(
|
|
|
_tasks[task_id]["status"] = "completed"
|
|
_tasks[task_id]["status"] = "completed"
|
|
|
_tasks[task_id]["progress"] = 100
|
|
_tasks[task_id]["progress"] = 100
|
|
|
_tasks[task_id]["message"] = f"处理完成: {len(all_entities)} 个实体, {len(all_relations)} 个关系"
|
|
_tasks[task_id]["message"] = f"处理完成: {len(all_entities)} 个实体, {len(all_relations)} 个关系"
|
|
|
- _tasks[task_id]["result"] = response.dict()
|
|
|
|
|
|
|
+ _tasks[task_id]["result"] = response.dict(by_alias=True)
|
|
|
_tasks[task_id]["updated_at"] = time.time()
|
|
_tasks[task_id]["updated_at"] = time.time()
|
|
|
|
|
|
|
|
logger.info(f"异步 NER 任务完成: task_id={task_id}, document_id={document_id}, "
|
|
logger.info(f"异步 NER 任务完成: task_id={task_id}, document_id={document_id}, "
|