this.setTaskStatisticsRequirements(this.opts)
}
+ /** @inheritDoc */
+ public hasPoolWorkerNodesReady (): boolean {
+ return this.pool.workerNodes.some(workerNode => workerNode.info.ready)
+ }
+
/**
* Whether the worker node is ready or not.
*
* @returns Whether the worker node is ready or not.
*/
protected isWorkerNodeReady (workerNodeKey: number): boolean {
- return this.pool.workerNodes[workerNodeKey]?.info.ready ?? false
+ return this.pool.workerNodes[workerNodeKey]?.info?.ready ?? false
}
/**
- * Whether the worker node has back pressure or not (i.e. its tasks queue is full).
- *
- * @param workerNodeKey - The worker node key.
- * @returns `true` if the worker node has back pressure, `false` otherwise.
+ * Check the next worker node readiness.
*/
- protected hasWorkerNodeBackPressure (workerNodeKey: number): boolean {
- return this.pool.hasWorkerNodeBackPressure(workerNodeKey)
+ protected checkNextWorkerNodeReadiness (): void {
+ if (!this.isWorkerNodeReady(this.nextWorkerNodeKey as number)) {
+ delete this.nextWorkerNodeKey
+ }
}
/**