X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=tests%2Fpools%2Fabstract%2Fabstract-pool.test.js;h=d3a71bc15f5f44e3fdbefe2f0c9d885e102caeed;hb=23ccf9d796ac950710863515ff45612a0456931d;hp=32f5bbeefa611bad7d32967d4701f99ebefd6cdd;hpb=bb4e9c3d36509745767905e4577d000087a23288;p=poolifier.git diff --git a/tests/pools/abstract/abstract-pool.test.js b/tests/pools/abstract/abstract-pool.test.js index 32f5bbee..d3a71bc1 100644 --- a/tests/pools/abstract/abstract-pool.test.js +++ b/tests/pools/abstract/abstract-pool.test.js @@ -11,6 +11,7 @@ const { } = require('../../../lib') const { CircularArray } = require('../../../lib/circular-array') const { Queue } = require('../../../lib/queue') +const { version } = require('../../../package.json') describe('Abstract pool test suite', () => { const numberOfWorkers = 2 @@ -393,6 +394,7 @@ describe('Abstract pool test suite', () => { './tests/worker-files/thread/testWorker.js' ) expect(pool.info).toStrictEqual({ + version, type: PoolTypes.fixed, worker: WorkerTypes.thread, minSize: numberOfWorkers, @@ -406,9 +408,6 @@ describe('Abstract pool test suite', () => { maxQueuedTasks: 0, failedTasks: 0 }) - for (const workerNode of pool.workerNodes) { - console.log('thread:workerNode.info', workerNode.info) - } await pool.destroy() pool = new DynamicClusterPool( numberOfWorkers, @@ -416,6 +415,7 @@ describe('Abstract pool test suite', () => { './tests/worker-files/cluster/testWorker.js' ) expect(pool.info).toStrictEqual({ + version, type: PoolTypes.dynamic, worker: WorkerTypes.cluster, minSize: numberOfWorkers, @@ -429,9 +429,6 @@ describe('Abstract pool test suite', () => { maxQueuedTasks: 0, failedTasks: 0 }) - for (const workerNode of pool.workerNodes) { - console.log('cluster:workerNode.info', workerNode.info) - } await pool.destroy() }) @@ -717,6 +714,7 @@ describe('Abstract pool test suite', () => { // So in total numberOfWorkers * 2 times for a loop submitting up to numberOfWorkers * 2 tasks to the dynamic pool with min = max = numberOfWorkers. expect(poolFull).toBe(numberOfWorkers * 2) expect(poolInfo).toStrictEqual({ + version, type: PoolTypes.dynamic, worker: WorkerTypes.thread, minSize: expect.any(Number), @@ -753,6 +751,7 @@ describe('Abstract pool test suite', () => { // So in total numberOfWorkers + 1 times for a loop submitting up to numberOfWorkers * 2 tasks to the fixed pool. expect(poolBusy).toBe(numberOfWorkers + 1) expect(poolInfo).toStrictEqual({ + version, type: PoolTypes.fixed, worker: WorkerTypes.thread, minSize: expect.any(Number),