summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
6cd5248)
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 &&
- workerNode.usage.tasks.executing <
- (this.opts.tasksQueueOptions?.concurrency as number)
- ) {
+ if (this.tasksQueueSize(workerNodeKey) === 0) {
this.executeTask(workerNodeKey, task)
} else {
this.enqueueTask(workerNodeKey, task)
this.executeTask(workerNodeKey, task)
} else {
this.enqueueTask(workerNodeKey, task)