)
expect(workerNode.workerUsage.tasks.executed).toBe(0)
expect(workerNode.workerUsage.tasks.queued).toBeGreaterThan(0)
+ expect(workerNode.workerUsage.tasks.maxQueued).toBeGreaterThan(0)
}
expect(queuePool.info.executingTasks).toBe(numberOfThreads)
expect(queuePool.info.queuedTasks).toBe(
maxMultiplier
)
expect(workerNode.workerUsage.tasks.queued).toBe(0)
+ expect(workerNode.workerUsage.tasks.maxQueued).toBe(1)
}
})