X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fleast-busy-worker-choice-strategy.ts;h=33199368c67b176a23920f407973aaf290e3a9be;hb=8b7aa4204c27efd1dc699f7baea65b5262bd26b3;hp=a9fe3d1c3f0eb779ea47d6907cbb8aed464e46d9;hpb=e0843544927da7ce67c7a6b84c5bf402dd47c1bb;p=poolifier.git diff --git a/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts b/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts index a9fe3d1c..33199368 100644 --- a/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/least-busy-worker-choice-strategy.ts @@ -5,12 +5,11 @@ import { AbstractWorkerChoiceStrategy } from './abstract-worker-choice-strategy. import type { IWorkerChoiceStrategy, TaskStatisticsRequirements, - WorkerChoiceStrategyOptions + WorkerChoiceStrategyOptions, } from './selection-strategies-types.js' /** * Selects the least busy worker. - * * @typeParam Worker - Type of worker which manages the strategy. * @typeParam Data - Type of data sent to the worker. This can only be structured-cloneable data. * @typeParam Response - Type of execution response. This can only be structured-cloneable data. @@ -27,14 +26,14 @@ export class LeastBusyWorkerChoiceStrategy< runTime: { aggregate: true, average: false, - median: false + median: false, }, waitTime: { aggregate: true, average: false, - median: false + median: false, }, - elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS + elu: DEFAULT_MEASUREMENT_STATISTICS_REQUIREMENTS, } /** @inheritDoc */ @@ -69,9 +68,6 @@ export class LeastBusyWorkerChoiceStrategy< } private leastBusyNextWorkerNodeKey (): number | undefined { - if (this.pool.workerNodes.length === 0) { - return undefined - } return this.pool.workerNodes.reduce( (minWorkerNodeKey, workerNode, workerNodeKey, workerNodes) => { return this.isWorkerNodeReady(workerNodeKey) &&