X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fcluster%2Fdynamic.test.js;h=a5250e538a2eedf562d43981998adf4207092e72;hb=7f6a4f12bee14a8489be1e289c099dc918006780;hp=291629f59b93f195eaf2d9b4a57f5e2649786af0;hpb=fe2dcd443af649ee75e8e66a3cff4174f072b015;p=poolifier.git diff --git a/tests/pools/cluster/dynamic.test.js b/tests/pools/cluster/dynamic.test.js index 291629f5..a5250e53 100644 --- a/tests/pools/cluster/dynamic.test.js +++ b/tests/pools/cluster/dynamic.test.js @@ -82,15 +82,15 @@ describe('Dynamic cluster pool test suite', () => { await pool1.destroy() }) - it('Verify scale processes up and down is working when long running task is used:hard', async () => { + it('Verify scale processes up and down is working when long executing task is used:hard', async () => { const longRunningPool = new DynamicClusterPool( min, max, './tests/worker-files/cluster/longRunningWorkerHardBehavior.js', { errorHandler: e => console.error(e), - onlineHandler: () => console.log('long running worker is online'), - exitHandler: () => console.log('long running worker exited') + onlineHandler: () => console.log('long executing worker is online'), + exitHandler: () => console.log('long executing worker exited') } ) expect(longRunningPool.workerNodes.length).toBe(min) @@ -109,15 +109,15 @@ describe('Dynamic cluster pool test suite', () => { await longRunningPool.destroy() }) - it('Verify scale processes up and down is working when long running task is used:soft', async () => { + it('Verify scale processes up and down is working when long executing task is used:soft', async () => { const longRunningPool = new DynamicClusterPool( min, max, './tests/worker-files/cluster/longRunningWorkerSoftBehavior.js', { errorHandler: e => console.error(e), - onlineHandler: () => console.log('long running worker is online'), - exitHandler: () => console.log('long running worker exited') + onlineHandler: () => console.log('long executing worker is online'), + exitHandler: () => console.log('long executing worker exited') } ) expect(longRunningPool.workerNodes.length).toBe(min) @@ -126,7 +126,7 @@ describe('Dynamic cluster pool test suite', () => { } expect(longRunningPool.workerNodes.length).toBe(max) await TestUtils.sleep(1500) - // Here we expect the workerNodes to be at the max size since the task is still running + // Here we expect the workerNodes to be at the max size since the task is still executing expect(longRunningPool.workerNodes.length).toBe(max) // We need to clean up the resources after our test await longRunningPool.destroy()