- if (
- this.isDynamicPool &&
- !this.workersTaskRunTime.has(chosenWorkerNodeKey)
- ) {
- this.initWorkerTaskRunTime(chosenWorkerNodeKey)
- }
- const workerTaskRunTime =
- this.workersTaskRunTime.get(chosenWorkerNodeKey)?.runTime ?? 0
- const workerTaskWeight =
- this.workersTaskRunTime.get(chosenWorkerNodeKey)?.weight ??
- this.defaultWorkerWeight
- if (workerTaskRunTime < workerTaskWeight) {
- this.setWorkerTaskRunTime(
- chosenWorkerNodeKey,
- workerTaskWeight,
- workerTaskRunTime +
- (this.getWorkerVirtualTaskRunTime(chosenWorkerNodeKey) ?? 0)
- )
+ const workerVirtualTaskRunTime = this.workerVirtualTaskRunTime
+ const workerWeight =
+ this.opts.weights?.[chosenWorkerNodeKey] ?? this.defaultWorkerWeight
+ if (workerVirtualTaskRunTime < workerWeight) {
+ this.workerVirtualTaskRunTime =
+ workerVirtualTaskRunTime +
+ this.getWorkerVirtualTaskRunTime(chosenWorkerNodeKey)