X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fcluster%2Ffixed.test.js;h=9fc2b1b456a4cc5e323a14a276f3633372dba596;hb=0e2c24b4aaed93a6768127f49d898ac427faa147;hp=4e5390d18f713ce306ed0a9c5cbb31a67e2e70e1;hpb=ee9f52959d4996f56712791e73994dfbeb0370f0;p=poolifier.git diff --git a/tests/pools/cluster/fixed.test.js b/tests/pools/cluster/fixed.test.js index 4e5390d1..9fc2b1b4 100644 --- a/tests/pools/cluster/fixed.test.js +++ b/tests/pools/cluster/fixed.test.js @@ -102,20 +102,20 @@ describe('Fixed cluster pool test suite', () => { expect(workerNode.tasksUsage.run).toBe(0) expect(workerNode.tasksQueue.size).toBeGreaterThan(0) } - expect(queuePool.numberOfRunningTasks).toBe(numberOfWorkers) - expect(queuePool.numberOfQueuedTasks).toBe( + expect(queuePool.info.runningTasks).toBe(numberOfWorkers) + expect(queuePool.info.queuedTasks).toBe( + numberOfWorkers * maxMultiplier - numberOfWorkers + ) + expect(queuePool.info.maxQueuedTasks).toBe( numberOfWorkers * maxMultiplier - numberOfWorkers ) await Promise.all(promises) for (const workerNode of queuePool.workerNodes) { expect(workerNode.tasksUsage.running).toBe(0) expect(workerNode.tasksUsage.run).toBeGreaterThan(0) - expect(workerNode.tasksUsage.run).toBeLessThanOrEqual( - numberOfWorkers * maxMultiplier - ) + expect(workerNode.tasksUsage.run).toBeLessThanOrEqual(maxMultiplier) expect(workerNode.tasksQueue.size).toBe(0) } - promises.clear() }) it('Verify that is possible to have a worker that return undefined', async () => {