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

web/ProcessingQueueItem: add pipeline result sizes only for fetch

Browse Source
This commit is contained in:
wukko 2025-05-23 00:19:10 +06:00
parent 7732188870
commit 9dc58b19bf
No known key found for this signature in database
GPG Key ID: 3E30B3F26C7B4AA2
1 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
web/src/components/queue/ProcessingQueueItem.svelte
View File

@ -86,18 +86,24 @@
const progress = getProgress(info, currentTasks);
const runningWorkers = info.pipeline.filter(w => w.workerId in currentTasks);
const running = [...new Set(runningWorkers.map(task => $t(`queue.state.running.${task.worker}`)))].join(', ');
const running = new Set(runningWorkers.map(task => task.worker));
const progresses = runningWorkers.map(w => currentTasks[w.workerId])
.map(t => t.progress)
.filter(p => p);
const totalSize =
progresses.reduce((s, p) => s + (p?.size ?? 0), 0) +
info.pipelineResults.reduce((s, p) => s + (p?.size ?? 0), 0);
let totalSize = progresses.reduce((s, p) => s + (p?.size ?? 0), 0);
// if only fetch workers are running, then we should
// show the sum of all running & completed fetch workers
if (running.size === 1 && running.has("fetch")) {
totalSize += info.pipelineResults.reduce((s, p) => s + (p?.size ?? 0), 0);
}
const runningText = [...running].map(task => $t(`queue.state.running.${task}`)).join(", ");
if (runningWorkers.length && totalSize > 0) {
const formattedSize = formatFileSize(totalSize);
return `${running}: ${Math.floor(progress * 100)}%, ${formattedSize}`;
return `${runningText}: ${Math.floor(progress * 100)}%, ${formattedSize}`;
}
const firstUnstarted = info.pipeline.find(w => {