|
@@ -53,9 +53,10 @@ class AgentTaskManager:
|
|
|
])).all()
|
|
|
|
|
|
def get_agent_task_details(self, task_id):
|
|
|
- """更新任务状态"""
|
|
|
+ """获取任务详情"""
|
|
|
with self.session_maker() as session:
|
|
|
- return session.query(AgentTaskDetail).filter(AgentTaskDetail.agent_task_id == task_id).all()
|
|
|
+ return session.query(AgentTaskDetail).filter(AgentTaskDetail.agent_task_id == task_id).filter(
|
|
|
+ AgentTaskDetail.parent_execution_id == None).all()
|
|
|
|
|
|
def save_agent_task_details_batch(self, agent_task_details: list, agent_task_id: int, message: str):
|
|
|
"""批量保存子任务到数据库"""
|