import { AbstractWorkerChoiceStrategy } from './abstract-worker-choice-strategy.js'
import type {
IWorkerChoiceStrategy,
- InternalWorkerChoiceStrategyOptions,
- TaskStatisticsRequirements
+ TaskStatisticsRequirements,
+ WorkerChoiceStrategyOptions
} from './selection-strategies-types.js'
/**
/** @inheritDoc */
public constructor (
pool: IPool<Worker, Data, Response>,
- opts: InternalWorkerChoiceStrategyOptions
+ opts?: WorkerChoiceStrategyOptions
) {
super(pool, opts)
this.setTaskStatisticsRequirements(this.opts)
this.workerNodeVirtualTaskRunTime = 0
}
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
- const workerWeight = this.opts.weights![workerNodeKey]!
+ const workerWeight = this.opts!.weights![workerNodeKey]!
if (
this.isWorkerNodeReady(workerNodeKey) &&
workerWeight >= this.roundWeights[roundIndex] &&
}
/** @inheritDoc */
- public setOptions (opts: InternalWorkerChoiceStrategyOptions): void {
+ public setOptions (opts: WorkerChoiceStrategyOptions | undefined): void {
super.setOptions(opts)
this.roundWeights = this.getRoundWeights()
}
return [
...new Set(
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
- Object.values(this.opts.weights!)
+ Object.values(this.opts!.weights!)
.slice()
.sort((a, b) => a - b)
)