@@ -271,6 +271,8 @@ class TaskManager:
{"status": TestTaskConversationsStatus.CANCELLED.value})
session.commit()
+ self._cleanup_task_resources(task_id)
+
def resume_task(self, task_id: int, user: str) -> bool:
"""恢复已取消的任务"""
task = self.get_task(task_id)