test: remove duplicate tests

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>

diff --git a/tests/pools/cluster/dynamic.test.mjs b/tests/pools/cluster/dynamic.test.mjs
index f509445220fda049d96e52bbd37b95dbae0a4094..c93a67116ab35fe51750c005c32c3fb67bf156c2 100644 (file)
--- a/tests/pools/cluster/dynamic.test.mjs
+++ b/tests/pools/cluster/dynamic.test.mjs
@@ -11,14 +11,18 @@ import { sleep, waitPoolEvents, waitWorkerEvents } from '../../test-utils.cjs'
 describe('Dynamic cluster pool test suite', () => {
   const min = 1
   const max = 3
-  const pool = new DynamicClusterPool(
-    min,
-    max,
-    './tests/worker-files/cluster/testWorker.cjs',
-    {
-      errorHandler: e => console.error(e),
-    }
-  )
+  let pool
+
+  before('Create pool', () => {
+    pool = new DynamicClusterPool(
+      min,
+      max,
+      './tests/worker-files/cluster/testWorker.cjs',
+      {
+        errorHandler: e => console.error(e),
+      }
+    )
+  })
 
   it('Verify that the function is executed in a worker cluster', async () => {
     let result = await pool.execute({
@@ -88,18 +92,6 @@ describe('Dynamic cluster pool test suite', () => {
     )
   })
 
-  it('Should work even without opts in input', async () => {
-    const pool = new DynamicClusterPool(
-      min,
-      max,
-      './tests/worker-files/cluster/testWorker.cjs'
-    )
-    const result = await pool.execute()
-    expect(result).toStrictEqual({ ok: 1 })
-    // We need to clean up the resources after our test
-    await pool.destroy()
-  })
-
   it('Verify scale processes up and down is working when long executing task is used:hard', async () => {
     const longRunningPool = new DynamicClusterPool(
       min,

diff --git a/tests/pools/cluster/fixed.test.mjs b/tests/pools/cluster/fixed.test.mjs
index c42792368d82c4223f6e822489efd108a8b288c7..68808f60d582ae786c13292b776b00d14ec3c832 100644 (file)
--- a/tests/pools/cluster/fixed.test.mjs
+++ b/tests/pools/cluster/fixed.test.mjs
@@ -313,15 +313,6 @@ describe('Fixed cluster pool test suite', () => {
     await pool.destroy()
   })
 
-  it('Should work even without opts in input', async () => {
-    const workerFilePath = './tests/worker-files/cluster/testWorker.cjs'
-    const pool = new FixedClusterPool(numberOfWorkers, workerFilePath)
-    const res = await pool.execute()
-    expect(res).toStrictEqual({ ok: 1 })
-    // We need to clean up the resources after our test
-    await pool.destroy()
-  })
-
   it('Verify destroyWorkerNode()', async () => {
     const workerFilePath = './tests/worker-files/cluster/testWorker.cjs'
     const pool = new FixedClusterPool(numberOfWorkers, workerFilePath)

diff --git a/tests/pools/thread/dynamic.test.mjs b/tests/pools/thread/dynamic.test.mjs
index 97bfbbfcebc4b17862c242279912a65d0918ef04..ab2d7f9c54daa173b75b12788f34a7e9a05b72cc 100644 (file)
--- a/tests/pools/thread/dynamic.test.mjs
+++ b/tests/pools/thread/dynamic.test.mjs
@@ -11,14 +11,18 @@ import { sleep, waitPoolEvents, waitWorkerEvents } from '../../test-utils.cjs'
 describe('Dynamic thread pool test suite', () => {
   const min = 1
   const max = 3
-  const pool = new DynamicThreadPool(
-    min,
-    max,
-    './tests/worker-files/thread/testWorker.mjs',
-    {
-      errorHandler: e => console.error(e),
-    }
-  )
+  let pool
+
+  before('Create pool', () => {
+    pool = new DynamicThreadPool(
+      min,
+      max,
+      './tests/worker-files/thread/testWorker.mjs',
+      {
+        errorHandler: e => console.error(e),
+      }
+    )
+  })
 
   it('Verify that the function is executed in a worker thread', async () => {
     let result = await pool.execute({
@@ -88,18 +92,6 @@ describe('Dynamic thread pool test suite', () => {
     )
   })
 
-  it('Should work even without opts in input', async () => {
-    const pool = new DynamicThreadPool(
-      min,
-      max,
-      './tests/worker-files/thread/testWorker.mjs'
-    )
-    const res = await pool.execute()
-    expect(res).toStrictEqual({ ok: 1 })
-    // We need to clean up the resources after our test
-    await pool.destroy()
-  })
-
   it('Verify scale thread up and down is working when long executing task is used:hard', async () => {
     const longRunningPool = new DynamicThreadPool(
       min,

diff --git a/tests/pools/thread/fixed.test.mjs b/tests/pools/thread/fixed.test.mjs
index e78ed180b290963d30f6f2ce7b1e908b8b6383f9..15698ae70b6ba983d83b3eb2e537ba76c71453a7 100644 (file)
--- a/tests/pools/thread/fixed.test.mjs
+++ b/tests/pools/thread/fixed.test.mjs
@@ -333,15 +333,6 @@ describe('Fixed thread pool test suite', () => {
     await pool.destroy()
   })
 
-  it('Should work even without opts in input', async () => {
-    const workerFilePath = './tests/worker-files/thread/testWorker.mjs'
-    const pool = new FixedThreadPool(numberOfThreads, workerFilePath)
-    const res = await pool.execute()
-    expect(res).toStrictEqual({ ok: 1 })
-    // We need to clean up the resources after our test
-    await pool.destroy()
-  })
-
   it('Verify destroyWorkerNode()', async () => {
     const workerFilePath = './tests/worker-files/thread/testWorker.mjs'
     const pool = new FixedThreadPool(numberOfThreads, workerFilePath)