X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fabstract-pool.ts;h=056d297273d82057e5a4202ddabd5dffba8c16f1;hb=eb8afc8aca35901acd45efb54f41e157c098f23e;hp=026bf918a40ce0158c3c159cd7734a6919f6e9c7;hpb=a15339d10554e3130fa1d8957163cb29a8eb2c41;p=poolifier.git diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts index 026bf918..056d2972 100644 --- a/src/pools/abstract-pool.ts +++ b/src/pools/abstract-pool.ts @@ -675,11 +675,11 @@ export abstract class AbstractPool< const workerUsage = this.workerNodes[workerNodeKey].usage ++workerUsage.tasks.executing this.updateWaitTimeWorkerUsage(workerUsage, task) - const tasksWorkerUsage = this.workerNodes[workerNodeKey].getTaskWorkerUsage( + const taskWorkerUsage = this.workerNodes[workerNodeKey].getTaskWorkerUsage( task.name as string ) as WorkerUsage - ++tasksWorkerUsage.tasks.executing - this.updateWaitTimeWorkerUsage(tasksWorkerUsage, task) + ++taskWorkerUsage.tasks.executing + this.updateWaitTimeWorkerUsage(taskWorkerUsage, task) } /** @@ -698,12 +698,12 @@ export abstract class AbstractPool< this.updateTaskStatisticsWorkerUsage(workerUsage, message) this.updateRunTimeWorkerUsage(workerUsage, message) this.updateEluWorkerUsage(workerUsage, message) - const tasksWorkerUsage = this.workerNodes[workerNodeKey].getTaskWorkerUsage( + const taskWorkerUsage = this.workerNodes[workerNodeKey].getTaskWorkerUsage( message.name as string ) as WorkerUsage - this.updateTaskStatisticsWorkerUsage(tasksWorkerUsage, message) - this.updateRunTimeWorkerUsage(tasksWorkerUsage, message) - this.updateEluWorkerUsage(tasksWorkerUsage, message) + this.updateTaskStatisticsWorkerUsage(taskWorkerUsage, message) + this.updateRunTimeWorkerUsage(taskWorkerUsage, message) + this.updateEluWorkerUsage(taskWorkerUsage, message) } private updateTaskStatisticsWorkerUsage (