X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fcluster%2Ffixed.test.js;h=9fc2b1b456a4cc5e323a14a276f3633372dba596;hb=0e2c24b4aaed93a6768127f49d898ac427faa147;hp=dfd765574a7437ef9ac128c9a35d7185cb7ab10b;hpb=fc027381650624a242a2e7b139976d52c3aa304c;p=poolifier.git diff --git a/tests/pools/cluster/fixed.test.js b/tests/pools/cluster/fixed.test.js index dfd76557..9fc2b1b4 100644 --- a/tests/pools/cluster/fixed.test.js +++ b/tests/pools/cluster/fixed.test.js @@ -102,8 +102,11 @@ 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) @@ -113,7 +116,6 @@ describe('Fixed cluster pool test suite', () => { 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 () => {