Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
...(sourceWorkerNode.popTask() as Task<Data>),
workerId: workerNode.info.id as number
}
...(sourceWorkerNode.popTask() as Task<Data>),
workerId: workerNode.info.id as number
}
- if (this.tasksQueueSize(workerNodeKey) === 0) {
+ if (
+ this.tasksQueueSize(workerNodeKey) === 0 &&
+ workerNode.usage.tasks.executing <
+ (this.opts.tasksQueueOptions?.concurrency as number)
+ ) {
this.executeTask(workerNodeKey, task)
} else {
this.enqueueTask(workerNodeKey, task)
this.executeTask(workerNodeKey, task)
} else {
this.enqueueTask(workerNodeKey, task)