mirrors/cobalt
1
0
Fork 0
mirror of https://github.com/imputnet/cobalt.git synced 2025-06-29 01:48:28 +00:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

web/ProcessingQueue: use full progress per item, not just running task

Browse Source
This commit is contained in:
wukko 2025-01-31 21:59:44 +06:00
parent 398c5402d2
commit 2ae0fd01dd
No known key found for this signature in database
GPG Key ID: 3E30B3F26C7B4AA2
1 changed files with 12 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
web/src/components/queue/ProcessingQueue.svelte
View File

@ -19,11 +19,20 @@
$: queue = Object.entries($readableQueue); $: queue = Object.entries($readableQueue);
const totalItemProgress = (completed: number, current: number, total: number) => {
return (completed * 100 + current) / total
}
$: totalProgress = queue.length ? queue.map(([, item]) => { $: totalProgress = queue.length ? queue.map(([, item]) => {
if (item.state === "done" || item.state === "error") if (item.state === "done" || item.state === "error") {
return 100; return 100;
else if (item.state === "running") } else if (item.state === "running") {
return $currentTasks[item.runningWorker]?.progress?.percentage || 0; return totalItemProgress(
item.completedWorkers?.length || 0,
$currentTasks[item.runningWorker]?.progress?.percentage || 0,
item.pipeline.length || 0
);
}
return 0; return 0;
}).reduce((a, b) => a + b) / (100 * queue.length) : 0; }).reduce((a, b) => a + b) / (100 * queue.length) : 0;