diff --git a/web/src/lib/queen-bee/run-worker.ts b/web/src/lib/queen-bee/run-worker.ts index 72f56006..fee96547 100644 --- a/web/src/lib/queen-bee/run-worker.ts +++ b/web/src/lib/queen-bee/run-worker.ts @@ -36,7 +36,7 @@ export const startWorker = async ({ worker, workerId, parentId, workerArgs }: Co files, workerArgs.ffargs, workerArgs.output, - true, // resetStartCounter + /*resetStartCounter=*/true, ); } break; diff --git a/web/src/lib/queen-bee/runners/remux.ts b/web/src/lib/queen-bee/runners/remux.ts index 4ffaf11e..60784759 100644 --- a/web/src/lib/queen-bee/runners/remux.ts +++ b/web/src/lib/queen-bee/runners/remux.ts @@ -16,7 +16,7 @@ export const runRemuxWorker = async ( files: CobaltFileReference[], args: string[], output: FileInfo, - resetStartCounter?: boolean + resetStartCounter = false ) => { const worker = new RemuxWorker(); diff --git a/web/src/lib/state/queen-bee/current-tasks.ts b/web/src/lib/state/queen-bee/current-tasks.ts index 528197d6..dd398b12 100644 --- a/web/src/lib/state/queen-bee/current-tasks.ts +++ b/web/src/lib/state/queen-bee/current-tasks.ts @@ -5,7 +5,7 @@ import type { CobaltCurrentTasks, CobaltCurrentTaskItem } from "$lib/types/queen let update: (_: Updater) => void; -const currentTasks = readable( +export const currentTasks = readable( {}, (_, _update) => { update = _update } ); @@ -36,5 +36,3 @@ export function clearCurrentTasks() { return {}; }); } - -export { currentTasks }; diff --git a/web/src/lib/state/queen-bee/queue.ts b/web/src/lib/state/queen-bee/queue.ts index ff5a2b64..b8c52f93 100644 --- a/web/src/lib/state/queen-bee/queue.ts +++ b/web/src/lib/state/queen-bee/queue.ts @@ -23,7 +23,7 @@ const clearPipelineCache = (queueItem: CobaltQueueItem) => { let update: (_: Updater) => void; -const queue = readable( +export const queue = readable( {}, (_, _update) => { update = _update } ); @@ -117,12 +117,7 @@ export function removeItem(id: string) { } export function clearQueue() { - update(() => { - return {}; - }); - + update(() => ({})); clearCurrentTasks(); clearFileStorage(); } - -export { queue };