X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fselection-strategies%2Fweighted-round-robin-worker-choice-strategy.ts;h=ad20db423826aa46a649da5512a3358e9f119572;hb=0d80593b9a7596645612087f687fc6f5cab3101a;hp=b0750949749de7f2d22ec0c97733b2f3ea5ec8b9;hpb=08f3f44cef6256fdbab1a2a56842b291fd6dcd42;p=poolifier.git diff --git a/src/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.ts b/src/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.ts index b0750949..ad20db42 100644 --- a/src/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.ts +++ b/src/pools/selection-strategies/weighted-round-robin-worker-choice-strategy.ts @@ -64,12 +64,12 @@ export class WeightedRoundRobinWorkerChoiceStrategy< /** @inheritDoc */ public choose (): number { const chosenWorkerNodeKey = this.currentWorkerNodeId - const workerTaskRunTime = this.workerVirtualTaskRunTime ?? 0 + const workerVirtualTaskRunTime = this.workerVirtualTaskRunTime ?? 0 const workerTaskWeight = this.opts.weights?.[chosenWorkerNodeKey] ?? this.defaultWorkerWeight - if (workerTaskRunTime < workerTaskWeight) { + if (workerVirtualTaskRunTime < workerTaskWeight) { this.workerVirtualTaskRunTime = - workerTaskRunTime + + workerVirtualTaskRunTime + (this.getWorkerVirtualTaskRunTime(chosenWorkerNodeKey) ?? 0) } else { this.currentWorkerNodeId =