From 8e3b29822fe425b842749b047ab1a17777d69a68 Mon Sep 17 00:00:00 2001 From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= Date: Wed, 25 Oct 2023 18:48:49 +0200 Subject: [PATCH] refactor: partially revert wrong change MIME-Version: 1.0 Content-Type: text/plain; charset=utf8 Content-Transfer-Encoding: 8bit Signed-off-by: Jérôme Benoit --- CHANGELOG.md | 1 - src/pools/abstract-pool.ts | 7 ------- 2 files changed, 8 deletions(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index eb0fa9cd..68d1da23 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -9,7 +9,6 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ### Fixed -- Ensure worker ready response can be received only once. - Ensure pool ready event can be emitted only once. ## [3.0.4] - 2023-10-20 diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts index 1140ca1b..604c7af8 100644 --- a/src/pools/abstract-pool.ts +++ b/src/pools/abstract-pool.ts @@ -1540,13 +1540,6 @@ export abstract class AbstractPool< const workerInfo = this.getWorkerInfo( this.getWorkerNodeKeyByWorkerId(message.workerId) ) - if (!this.started && workerInfo.ready) { - throw new Error( - `Ready response already received by worker ${ - message.workerId as number - }` - ) - } workerInfo.ready = message.ready as boolean workerInfo.taskFunctionNames = message.taskFunctionNames if (this.ready) { -- 2.34.1