diff --git a/karton/dashboard/app.py b/karton/dashboard/app.py index 51cd9bf..81eb001 100644 --- a/karton/dashboard/app.py +++ b/karton/dashboard/app.py @@ -42,6 +42,11 @@ ) +def cancel_tasks(tasks: List[Task]) -> None: + for task in tasks: + karton.backend.set_task_status(task=task, status=TaskState.FINISHED) + + class TaskView: """ All problems in computer science can be solved by another @@ -259,7 +264,7 @@ def cancel_crashed_queue_tasks(queue_name): if not queue: return jsonify({"error": "Queue doesn't exist"}), 404 - karton.backend.delete_tasks(queue.crashed_tasks) + cancel_tasks(queue.crashed_tasks) return redirect(request.referrer) @@ -270,7 +275,7 @@ def cancel_pending_queue_tasks(queue_name): if not queue: return jsonify({"error": "Queue doesn't exist"}), 404 - karton.backend.delete_tasks(queue.pending_tasks) + cancel_tasks(queue.pending_tasks) return redirect(request.referrer) @@ -290,7 +295,7 @@ def cancel_task(task_id): if not task: return jsonify({"error": "Task doesn't exist"}), 404 - karton.backend.delete_tasks([task]) + cancel_tasks([task]) return redirect(request.referrer)