queuePool.opts.tasksQueueOptions.concurrency
)
expect(workerNode.workerUsage.tasks.executed).toBe(0)
- expect(workerNode.tasksQueue.size).toBeGreaterThan(0)
+ expect(workerNode.workerUsage.tasks.queued).toBeGreaterThan(0)
}
expect(queuePool.info.executingTasks).toBe(numberOfWorkers)
expect(queuePool.info.queuedTasks).toBe(
expect(workerNode.workerUsage.tasks.executed).toBeLessThanOrEqual(
maxMultiplier
)
- expect(workerNode.tasksQueue.size).toBe(0)
+ expect(workerNode.workerUsage.tasks.queued).toBe(0)
}
})