From 87e44747b0b3f50f97b242e4fa1665b017ff0879 Mon Sep 17 00:00:00 2001 From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= Date: Mon, 10 Jul 2023 00:43:17 +0200 Subject: [PATCH] fix: fix task function statistics tracking MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit Signed-off-by: Jérôme Benoit --- CHANGELOG.md | 4 ++++ src/pools/abstract-pool.ts | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index 02964beb..b2d3b811 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -7,6 +7,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ## [Unreleased] +### Fixed + +- Fix task function statistics tracking. + ## [2.6.13] - 2023-07-10 ### Added diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts index 056d2972..c200d531 100644 --- a/src/pools/abstract-pool.ts +++ b/src/pools/abstract-pool.ts @@ -699,7 +699,7 @@ export abstract class AbstractPool< this.updateRunTimeWorkerUsage(workerUsage, message) this.updateEluWorkerUsage(workerUsage, message) const taskWorkerUsage = this.workerNodes[workerNodeKey].getTaskWorkerUsage( - message.name as string + message.taskPerformance?.name ?? DEFAULT_TASK_NAME ) as WorkerUsage this.updateTaskStatisticsWorkerUsage(taskWorkerUsage, message) this.updateRunTimeWorkerUsage(taskWorkerUsage, message) -- 2.34.1