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) => void; @@ -103,6 +103,8 @@ export function clearQueue() { update(() => { return {}; }); + + clearCurrentTasks(); } export { queue };