X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Finterleaved-weighted-round-robin-worker-choice-strategy.ts;h=0b32bd457af259810459fe6148aacf6dd95e06bd;hb=86ed05989a886c9e44d5be0089d5381debfb2294;hp=be76225680abdc580b3a86248206860566d742e7;hpb=d854790162e5f554fdda30b082d362fe14a9ac43;p=poolifier.git diff --git a/src/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.ts b/src/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.ts index be762256..0b32bd45 100644 --- a/src/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/interleaved-weighted-round-robin-worker-choice-strategy.ts @@ -96,9 +96,6 @@ export class InterleavedWeightedRoundRobinWorkerChoiceStrategy< workerNodeKey++ ) { this.workerNodeId = workerNodeKey - if (!this.isWorkerNodeEligible(workerNodeKey)) { - continue - } if ( this.workerNodeId !== this.nextWorkerNodeKey && this.workerVirtualTaskRunTime !== 0 @@ -114,8 +111,7 @@ export class InterleavedWeightedRoundRobinWorkerChoiceStrategy< this.workerVirtualTaskRunTime = this.workerVirtualTaskRunTime + this.getWorkerTaskRunTime(workerNodeKey) - this.previousWorkerNodeKey = - this.nextWorkerNodeKey ?? this.previousWorkerNodeKey + this.setPreviousWorkerNodeKey(this.nextWorkerNodeKey) this.nextWorkerNodeKey = workerNodeKey return this.nextWorkerNodeKey }