X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fcluster%2Fdynamic.test.js;h=c737c1d90ebc08743d5ae2a0af99c8957433376c;hb=09c2d0d3bf72a566a9460155ef62b052e53411aa;hp=e67d92bdb9849d05c09801a865e548a8208a4470;hpb=cdace0e5b9082804893de9501372490ee1064090;p=poolifier.git diff --git a/tests/pools/cluster/dynamic.test.js b/tests/pools/cluster/dynamic.test.js index e67d92bd..c737c1d9 100644 --- a/tests/pools/cluster/dynamic.test.js +++ b/tests/pools/cluster/dynamic.test.js @@ -19,11 +19,11 @@ describe('Dynamic cluster pool test suite', () => { let result = await pool.execute({ function: WorkerFunctions.fibonacci }) - expect(result).toBe(false) + expect(result).toBe(121393) result = await pool.execute({ function: WorkerFunctions.factorial }) - expect(result).toBe(false) + expect(result).toBe(9.33262154439441e157) }) it('Verify that new workers are created when required, max size is not exceeded and that after a while new workers will die', async () => { @@ -43,13 +43,13 @@ describe('Dynamic cluster pool test suite', () => { it('Verify scale worker up and down is working', async () => { expect(pool.workerNodes.length).toBe(min) - for (let i = 0; i < max * 10; i++) { + for (let i = 0; i < max * 2; i++) { pool.execute() } expect(pool.workerNodes.length).toBeGreaterThan(min) await TestUtils.waitExits(pool, max - min) expect(pool.workerNodes.length).toBe(min) - for (let i = 0; i < max * 10; i++) { + for (let i = 0; i < max * 2; i++) { pool.execute() } expect(pool.workerNodes.length).toBeGreaterThan(min) @@ -94,7 +94,7 @@ describe('Dynamic cluster pool test suite', () => { } ) expect(longRunningPool.workerNodes.length).toBe(min) - for (let i = 0; i < max * 10; i++) { + for (let i = 0; i < max * 2; i++) { longRunningPool.execute() } expect(longRunningPool.workerNodes.length).toBe(max) @@ -121,7 +121,7 @@ describe('Dynamic cluster pool test suite', () => { } ) expect(longRunningPool.workerNodes.length).toBe(min) - for (let i = 0; i < max * 10; i++) { + for (let i = 0; i < max * 2; i++) { longRunningPool.execute() } expect(longRunningPool.workerNodes.length).toBe(max)