From 6a307669ef6f5aae3a8b79504255a8d3bdfd7c86 Mon Sep 17 00:00:00 2001
From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= <jerome.benoit@piment-noir.org>
Date: Thu, 29 Aug 2024 19:12:32 +0200
Subject: [PATCH] test: refine pool event tests expectation
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
---
 tests/pools/abstract-pool.test.mjs | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

diff --git a/tests/pools/abstract-pool.test.mjs b/tests/pools/abstract-pool.test.mjs
index 2e6ba76b..63162e3a 100644
--- a/tests/pools/abstract-pool.test.mjs
+++ b/tests/pools/abstract-pool.test.mjs
@@ -1178,12 +1178,12 @@ describe('Abstract pool test suite', () => {
     await Promise.all(promises)
     expect(poolBusy).toBe(1)
     expect(poolBusyInfo).toStrictEqual({
-      busyWorkerNodes: expect.any(Number),
+      busyWorkerNodes: numberOfWorkers,
       defaultStrategy: WorkerChoiceStrategies.ROUND_ROBIN,
       executedTasks: expect.any(Number),
       executingTasks: expect.any(Number),
       failedTasks: expect.any(Number),
-      idleWorkerNodes: expect.any(Number),
+      idleWorkerNodes: 0,
       maxSize: numberOfWorkers,
       minSize: numberOfWorkers,
       ready: true,
@@ -1212,6 +1212,7 @@ describe('Abstract pool test suite', () => {
       worker: WorkerTypes.thread,
       workerNodes: numberOfWorkers,
     })
+    expect(poolBusyEndInfo.busyWorkerNodes).toBeLessThan(numberOfWorkers)
     await pool.destroy()
   })
 
@@ -1316,7 +1317,7 @@ describe('Abstract pool test suite', () => {
     expect(poolBackPressure).toBe(1)
     expect(poolBackPressureInfo).toStrictEqual({
       backPressure: true,
-      backPressureWorkerNodes: expect.any(Number),
+      backPressureWorkerNodes: numberOfWorkers,
       busyWorkerNodes: expect.any(Number),
       defaultStrategy: WorkerChoiceStrategies.ROUND_ROBIN,
       executedTasks: expect.any(Number),
@@ -1361,6 +1362,9 @@ describe('Abstract pool test suite', () => {
       worker: WorkerTypes.thread,
       workerNodes: numberOfWorkers,
     })
+    expect(poolBackPressureEndInfo.backPressureWorkerNodes).toBeLessThan(
+      numberOfWorkers
+    )
     await pool.destroy()
   })
 
-- 
2.34.1