|
|
@@ -270,8 +270,14 @@ async def _process_ner_task(
|
|
|
_tasks[task_id]["status"] = "completed"
|
|
|
_tasks[task_id]["progress"] = 100
|
|
|
_tasks[task_id]["message"] = f"处理完成: {len(all_entities)} 个实体, {len(all_relations)} 个关系"
|
|
|
- _tasks[task_id]["result"] = response.dict(by_alias=True)
|
|
|
+ result_dict = response.dict(by_alias=True)
|
|
|
+ _tasks[task_id]["result"] = result_dict
|
|
|
_tasks[task_id]["updated_at"] = time.time()
|
|
|
+
|
|
|
+ # 调试:输出第一个实体的序列化结果
|
|
|
+ if result_dict.get("entities") and len(result_dict["entities"]) > 0:
|
|
|
+ first_entity = result_dict["entities"][0]
|
|
|
+ logger.debug(f"实体序列化示例: {first_entity}")
|
|
|
|
|
|
logger.info(f"异步 NER 任务完成: task_id={task_id}, document_id={document_id}, "
|
|
|
f"entities={len(all_entities)}, relations={len(all_relations)}, time={processing_time}ms")
|