We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent d0d8e37 commit 5de50d9Copy full SHA for 5de50d9
src/types/queue/Queue.durationAvg.ts
@@ -17,15 +17,17 @@ export function createDurationAvgFC(
17
resolve: async (queue: Queue, { limit }) => {
18
const jobs = await queue.getCompleted(0, limit);
19
let amount = 0;
20
+ let counter = 0;
21
if (jobs.length === 0) {
22
return 0;
23
} else {
24
for (const job of jobs) {
- if (job.finishedOn && job.processedOn) {
25
- amount += job.finishedOn - job?.processedOn;
+ if (job?.finishedOn && job?.processedOn) {
26
+ amount += job.finishedOn - job.processedOn;
27
+ counter++;
28
}
29
- return (amount / jobs.length).toFixed(0);
30
+ return (amount / (counter || 1)).toFixed(0);
31
32
},
33
};
0 commit comments