refactor: cleanup task usage method namespace

[poolifier.git] / src / pools / abstract-pool.ts

diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts
index bb37dbb70fe4aac89115fc5da929270f0a39dd8d..615cf29604cdb1b2309b412be1df8f358d09958e 100644 (file)
--- a/src/pools/abstract-pool.ts
+++ b/src/pools/abstract-pool.ts
@@ -309,7 +309,7 @@ export abstract class AbstractPool<
       ),
       maxQueuedTasks: this.workerNodes.reduce(
         (accumulator, workerNode) =>
-          accumulator + workerNode.usage.tasks.maxQueued,
+          accumulator + (workerNode.usage.tasks?.maxQueued ?? 0),
         0
       ),
       failedTasks: this.workerNodes.reduce(
@@ -672,9 +672,9 @@ export abstract class AbstractPool<
     const workerUsage = this.workerNodes[workerNodeKey].usage
     ++workerUsage.tasks.executing
     this.updateWaitTimeWorkerUsage(workerUsage, task)
-    const tasksWorkerUsage = this.workerNodes[
-      workerNodeKey
-    ].getTasksWorkerUsage(task.name as string) as WorkerUsage
+    const tasksWorkerUsage = this.workerNodes[workerNodeKey].getTaskWorkerUsage(
+      task.name as string
+    ) as WorkerUsage
     ++tasksWorkerUsage.tasks.executing
     this.updateWaitTimeWorkerUsage(tasksWorkerUsage, task)
   }
@@ -695,9 +695,9 @@ export abstract class AbstractPool<
     this.updateTaskStatisticsWorkerUsage(workerUsage, message)
     this.updateRunTimeWorkerUsage(workerUsage, message)
     this.updateEluWorkerUsage(workerUsage, message)
-    const tasksWorkerUsage = this.workerNodes[
-      workerNodeKey
-    ].getTasksWorkerUsage(message.name as string) as WorkerUsage
+    const tasksWorkerUsage = this.workerNodes[workerNodeKey].getTaskWorkerUsage(
+      message.name as string
+    ) as WorkerUsage
     this.updateTaskStatisticsWorkerUsage(tasksWorkerUsage, message)
     this.updateRunTimeWorkerUsage(tasksWorkerUsage, message)
     this.updateEluWorkerUsage(tasksWorkerUsage, message)