From 6513ab38d04396c7afec94ece8ca1b7e6d98cbc8 Mon Sep 17 00:00:00 2001
From: wukko <me@wukko.me>
Date: Fri, 31 Jan 2025 22:02:35 +0600
Subject: [PATCH] web/state/queue: clear all current tasks on queue clear

---
 web/src/lib/state/queen-bee/current-tasks.ts | 2 +-
 web/src/lib/state/queen-bee/queue.ts         | 6 ++++--
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/web/src/lib/state/queen-bee/current-tasks.ts b/web/src/lib/state/queen-bee/current-tasks.ts
index aa413702..528197d6 100644
--- a/web/src/lib/state/queen-bee/current-tasks.ts
+++ b/web/src/lib/state/queen-bee/current-tasks.ts
@@ -31,7 +31,7 @@ export function updateWorkerProgress(workerId: string, progress: CobaltWorkerPro
     });
 }
 
-export function clearQueue() {
+export function clearCurrentTasks() {
     update(() => {
         return {};
     });
diff --git a/web/src/lib/state/queen-bee/queue.ts b/web/src/lib/state/queen-bee/queue.ts
index 43716d36..1ff45162 100644
--- a/web/src/lib/state/queen-bee/queue.ts
+++ b/web/src/lib/state/queen-bee/queue.ts
@@ -1,7 +1,7 @@
 import { readable, type Updater } from "svelte/store";
-import type { CobaltQueue, CobaltQueueItem } from "$lib/types/queue";
 import { checkTasks } from "$lib/queen-bee/scheduler";
-import { removeWorkerFromQueue } from "./current-tasks";
+import type { CobaltQueue, CobaltQueueItem } from "$lib/types/queue";
+import { clearCurrentTasks, removeWorkerFromQueue } from "$lib/state/queen-bee/current-tasks";
 
 let update: (_: Updater<CobaltQueue>) => void;
 
@@ -103,6 +103,8 @@ export function clearQueue() {
     update(() => {
         return {};
     });
+
+    clearCurrentTasks();
 }
 
 export { queue };