Mirrors/cobalt
1
0
Fork 0
mirror of https://github.com/wukko/cobalt.git synced 2025-05-22 19:09:00 +02:00
Code Issues Packages Projects Releases Wiki Activity

web/queue: refactor removeItem() and clearPipelineCache()

Browse Source
This commit is contained in:
jj 2025-03-29 14:19:59 +00:00
parent 165fa65964
commit 75e1fb689a
No known key found for this signature in database
1 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
web/src/lib/state/queen-bee/queue.ts
View File

@ -8,13 +8,12 @@ import type { CobaltFileReference } from "$lib/types/storage";
import type { CobaltQueue, CobaltQueueItem, CobaltQueueItemRunning } from "$lib/types/queue";
const clearPipelineCache = (queueItem: CobaltQueueItem) => {
if (queueItem.state === "running" && queueItem.pipelineResults) {
for (const item of queueItem.pipelineResults) {
if (queueItem.state === "running") {
let item: CobaltFileReference | undefined;
while ((item = queueItem.pipelineResults.pop())) {
removeFromFileStorage(item.file.name);
}
delete queueItem.pipelineResults;
}
if (queueItem.state === "done") {
} else if (queueItem.state === "done") {
removeFromFileStorage(queueItem.resultFile.file.name);
}
@ -107,12 +106,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]);
const item = queueData[id];
for (const worker of item.pipeline) {
removeWorkerFromQueue(worker.workerId);
}
clearPipelineCache(item);
delete queueData[id];
return queueData;