X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fcluster%2Fdynamic.test.mjs;h=2a654b6a878cab03a4da44afb7200ca122acf0c1;hb=af7f2788b6fcc39343d544551cf17c8f0dc5b757;hp=2c542375e5f5fda1b83daea9fe29c3d205150f49;hpb=55082af96253bead6fb8d4d648c454ba71a38fb6;p=poolifier.git diff --git a/tests/pools/cluster/dynamic.test.mjs b/tests/pools/cluster/dynamic.test.mjs index 2c542375..2a654b6a 100644 --- a/tests/pools/cluster/dynamic.test.mjs +++ b/tests/pools/cluster/dynamic.test.mjs @@ -37,10 +37,10 @@ describe('Dynamic cluster pool test suite', () => { expect(poolBusy).toBe(1) const numberOfExitEvents = await waitWorkerEvents(pool, 'exit', max - min) expect(numberOfExitEvents).toBe(max - min) + expect(pool.workerNodes.length).toBe(min) }) it('Verify scale worker up and down is working', async () => { - expect(pool.workerNodes.length).toBe(min) for (let i = 0; i < max * 2; i++) { pool.execute() } @@ -67,6 +67,7 @@ describe('Dynamic cluster pool test suite', () => { await pool.destroy() const numberOfExitEvents = await exitPromise expect(pool.started).toBe(false) + expect(pool.emitter.eventNames()).toStrictEqual([]) expect(pool.readyEventEmitted).toBe(false) expect(pool.workerNodes.length).toBe(0) expect(numberOfExitEvents).toBe(min) @@ -75,7 +76,7 @@ describe('Dynamic cluster pool test suite', () => { it('Validation of inputs test', () => { expect(() => new DynamicClusterPool(min)).toThrow( - "Cannot find the worker file 'undefined'" + 'The worker file path must be specified' ) })