return new Set([
// eslint-disable-next-line @typescript-eslint/no-non-null-assertion
this.opts.workerChoiceStrategy!,
- ...(this.listTaskFunctionsProperties()
+ ...this.listTaskFunctionsProperties()
.map(
(taskFunctionProperties: TaskFunctionProperties) =>
taskFunctionProperties.strategy
)
.filter(
(strategy: WorkerChoiceStrategy | undefined) => strategy != null
- ) as WorkerChoiceStrategy[]),
+ ),
])
}
})
}
-
/** @inheritDoc */
public mapExecute (
data: Iterable<Data>,
* @param initWorkerNodeUsage - Whether to initialize the worker node usage or not. @defaultValue false
*/
private startMinimumNumberOfWorkers (initWorkerNodeUsage = false): void {
+ if (this.minimumNumberOfWorkers === 0) {
+ return
+ }
this.startingMinimumNumberOfWorkers = true
while (
this.workerNodes.reduce(