|
@@ -90,10 +90,10 @@ class AgentTaskManager:
|
|
|
raise Exception(e)
|
|
|
|
|
|
def update_task_failed(self, task_id, error_message: str):
|
|
|
- """更新任务状态"""
|
|
|
+ """更新任务失败"""
|
|
|
with self.session_maker() as session:
|
|
|
session.query(AgentTask).filter(AgentTask.id == task_id).update(
|
|
|
- {"status": AgentTaskStatus.FAILED, "error_message": error_message, "update_time": datetime.now()})
|
|
|
+ {"status": AgentTaskStatus.FAILED.value, "error_message": error_message, "update_time": datetime.now()})
|
|
|
session.commit()
|
|
|
|
|
|
def update_task_status(self, task_id, status):
|