@@ -419,7 +419,7 @@ async def run_once(execution_id, merge_level2, task_id: Optional[int] = None) ->
except Exception:
# 兜底：即使写文件失败，也要确保 MySQL 状态被更新
pass
- # _finish_demand_task(task_id=task_id, status=task_status, task_log=task_log_text)
+ _finish_demand_task(task_id=task_id, status=task_status, task_log=task_log_text)
return final_text
xueyiming