web/state/queue: check if pipeline exists before removing workers

2025-02-03 18:08:47 +06:00
parent 6c18f1d460
commit 1716c1d2af
1 changed files with 5 additions and 3 deletions
--- a/web/src/lib/state/queen-bee/queue.ts
+++ b/web/src/lib/state/queen-bee/queue.ts
@@ -102,10 +102,12 @@ export function itemRunning(id: string, workerId: string) {

 export function removeItem(id: string) {
    update(queueData => {
+        if (queueData[id].pipeline) {
            for (const worker in queueData[id].pipeline) {
                removeWorkerFromQueue(queueData[id].pipeline[worker].workerId);
            }
            clearPipelineCache(queueData[id]);
+        }

        delete queueData[id];
        return queueData;