From efabc98de28009bfd9e9b7df262556d4c7444c89 Mon Sep 17 00:00:00 2001 From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= Date: Wed, 3 Jan 2024 23:14:06 +0100 Subject: [PATCH] fix: readd nullish checks on worker usage MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit Signed-off-by: Jérôme Benoit --- src/pools/abstract-pool.ts | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts index 4170b8b6..99744517 100644 --- a/src/pools/abstract-pool.ts +++ b/src/pools/abstract-pool.ts @@ -1061,7 +1061,7 @@ export abstract class AbstractPool< task: Task ): void { // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition - if (this.workerNodes[workerNodeKey].usage != null) { + if (this.workerNodes[workerNodeKey]?.usage != null) { const workerUsage = this.workerNodes[workerNodeKey].usage ++workerUsage.tasks.executing updateWaitTimeWorkerUsage( @@ -1103,7 +1103,7 @@ export abstract class AbstractPool< ): void { let needWorkerChoiceStrategyUpdate = false // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition - if (this.workerNodes[workerNodeKey].usage != null) { + if (this.workerNodes[workerNodeKey]?.usage != null) { const workerUsage = this.workerNodes[workerNodeKey].usage updateTaskStatisticsWorkerUsage(workerUsage, message) updateRunTimeWorkerUsage( @@ -1454,7 +1454,7 @@ export abstract class AbstractPool< ): void { const workerNode = this.workerNodes[workerNodeKey] // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition - if (workerNode.usage != null) { + if (workerNode?.usage != null) { ++workerNode.usage.tasks.stolen } if ( @@ -1473,7 +1473,7 @@ export abstract class AbstractPool< ): void { const workerNode = this.workerNodes[workerNodeKey] // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition - if (workerNode.usage != null) { + if (workerNode?.usage != null) { ++workerNode.usage.tasks.sequentiallyStolen } } @@ -1499,7 +1499,7 @@ export abstract class AbstractPool< ): void { const workerNode = this.workerNodes[workerNodeKey] // eslint-disable-next-line @typescript-eslint/no-unnecessary-condition - if (workerNode.usage != null) { + if (workerNode?.usage != null) { workerNode.usage.tasks.sequentiallyStolen = 0 } } -- 2.34.1