repositories
/
poolifier.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
build(deps-dev): bump @types/node
[poolifier.git]
/
tests
/
pools
/
abstract-pool.test.mjs
diff --git
a/tests/pools/abstract-pool.test.mjs
b/tests/pools/abstract-pool.test.mjs
index 44aca3993c7d94d9f52185e553333db2316a8a71..4b32e253a3aed5c203bfff7476d49a02a6b4488c 100644
(file)
--- a/
tests/pools/abstract-pool.test.mjs
+++ b/
tests/pools/abstract-pool.test.mjs
@@
-14,12
+14,12
@@
import {
PoolTypes,
WorkerChoiceStrategies,
WorkerTypes
PoolTypes,
WorkerChoiceStrategies,
WorkerTypes
-} from '../../lib/index.js'
-import { CircularArray } from '../../lib/circular-array.js'
-import { Deque } from '../../lib/deque.js'
-import { DEFAULT_TASK_NAME } from '../../lib/utils.js'
-import { waitPoolEvents } from '../test-utils.js'
-import { WorkerNode } from '../../lib/pools/worker-node.js'
+} from '../../lib/index.
c
js'
+import { CircularArray } from '../../lib/circular-array.
c
js'
+import { Deque } from '../../lib/deque.
c
js'
+import { DEFAULT_TASK_NAME } from '../../lib/utils.
c
js'
+import { waitPoolEvents } from '../test-utils.
c
js'
+import { WorkerNode } from '../../lib/pools/worker-node.
c
js'
describe('Abstract pool test suite', () => {
const version = JSON.parse(
describe('Abstract pool test suite', () => {
const version = JSON.parse(
@@
-105,7
+105,7
@@
describe('Abstract pool test suite', () => {
it('Verify that a negative number of workers is checked', () => {
expect(
() =>
it('Verify that a negative number of workers is checked', () => {
expect(
() =>
- new FixedClusterPool(-1, './tests/worker-files/cluster/testWorker.js')
+ new FixedClusterPool(-1, './tests/worker-files/cluster/testWorker.
c
js')
).toThrow(
new RangeError(
'Cannot instantiate a pool with a negative number of workers'
).toThrow(
new RangeError(
'Cannot instantiate a pool with a negative number of workers'
@@
-146,7
+146,7
@@
describe('Abstract pool test suite', () => {
new DynamicClusterPool(
1,
undefined,
new DynamicClusterPool(
1,
undefined,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
).toThrow(
new TypeError(
)
).toThrow(
new TypeError(
@@
-170,7
+170,7
@@
describe('Abstract pool test suite', () => {
new DynamicClusterPool(
0,
0.5,
new DynamicClusterPool(
0,
0.5,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
).toThrow(
new TypeError(
)
).toThrow(
new TypeError(
@@
-206,7
+206,7
@@
describe('Abstract pool test suite', () => {
new DynamicClusterPool(
1,
1,
new DynamicClusterPool(
1,
1,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
).toThrow(
new RangeError(
)
).toThrow(
new RangeError(
@@
-221,6
+221,7
@@
describe('Abstract pool test suite', () => {
'./tests/worker-files/thread/testWorker.mjs'
)
expect(pool.emitter).toBeInstanceOf(EventEmitterAsyncResource)
'./tests/worker-files/thread/testWorker.mjs'
)
expect(pool.emitter).toBeInstanceOf(EventEmitterAsyncResource)
+ expect(pool.emitter.eventNames()).toStrictEqual([])
expect(pool.opts).toStrictEqual({
startWorkers: true,
enableEvents: true,
expect(pool.opts).toStrictEqual({
startWorkers: true,
enableEvents: true,
@@
-228,19
+229,16
@@
describe('Abstract pool test suite', () => {
enableTasksQueue: false,
workerChoiceStrategy: WorkerChoiceStrategies.ROUND_ROBIN
})
enableTasksQueue: false,
workerChoiceStrategy: WorkerChoiceStrategies.ROUND_ROBIN
})
- expect(pool.workerChoiceStrategyContext.opts).toStrictEqual({
- retries: pool.info.maxSize,
- runTime: { median: false },
- waitTime: { median: false },
- elu: { median: false }
- })
for (const [, workerChoiceStrategy] of pool.workerChoiceStrategyContext
.workerChoiceStrategies) {
expect(workerChoiceStrategy.opts).toStrictEqual({
for (const [, workerChoiceStrategy] of pool.workerChoiceStrategyContext
.workerChoiceStrategies) {
expect(workerChoiceStrategy.opts).toStrictEqual({
- retries: pool.info.maxSize,
runTime: { median: false },
waitTime: { median: false },
runTime: { median: false },
waitTime: { median: false },
- elu: { median: false }
+ elu: { median: false },
+ weights: expect.objectContaining({
+ 0: expect.any(Number),
+ [pool.info.maxSize - 1]: expect.any(Number)
+ })
})
}
await pool.destroy()
})
}
await pool.destroy()
@@
-287,17
+285,9
@@
describe('Abstract pool test suite', () => {
errorHandler: testHandler,
exitHandler: testHandler
})
errorHandler: testHandler,
exitHandler: testHandler
})
- expect(pool.workerChoiceStrategyContext.opts).toStrictEqual({
- retries: pool.info.maxSize,
- runTime: { median: true },
- waitTime: { median: false },
- elu: { median: false },
- weights: { 0: 300, 1: 200 }
- })
for (const [, workerChoiceStrategy] of pool.workerChoiceStrategyContext
.workerChoiceStrategies) {
expect(workerChoiceStrategy.opts).toStrictEqual({
for (const [, workerChoiceStrategy] of pool.workerChoiceStrategyContext
.workerChoiceStrategies) {
expect(workerChoiceStrategy.opts).toStrictEqual({
- retries: pool.info.maxSize,
runTime: { median: true },
waitTime: { median: false },
elu: { median: false },
runTime: { median: true },
waitTime: { median: false },
elu: { median: false },
@@
-454,19
+444,16
@@
describe('Abstract pool test suite', () => {
{ workerChoiceStrategy: WorkerChoiceStrategies.FAIR_SHARE }
)
expect(pool.opts.workerChoiceStrategyOptions).toBeUndefined()
{ workerChoiceStrategy: WorkerChoiceStrategies.FAIR_SHARE }
)
expect(pool.opts.workerChoiceStrategyOptions).toBeUndefined()
- expect(pool.workerChoiceStrategyContext.opts).toStrictEqual({
- retries: pool.info.maxSize,
- runTime: { median: false },
- waitTime: { median: false },
- elu: { median: false }
- })
for (const [, workerChoiceStrategy] of pool.workerChoiceStrategyContext
.workerChoiceStrategies) {
expect(workerChoiceStrategy.opts).toStrictEqual({
for (const [, workerChoiceStrategy] of pool.workerChoiceStrategyContext
.workerChoiceStrategies) {
expect(workerChoiceStrategy.opts).toStrictEqual({
- retries: pool.info.maxSize,
runTime: { median: false },
waitTime: { median: false },
runTime: { median: false },
waitTime: { median: false },
- elu: { median: false }
+ elu: { median: false },
+ weights: expect.objectContaining({
+ 0: expect.any(Number),
+ [pool.info.maxSize - 1]: expect.any(Number)
+ })
})
}
expect(
})
}
expect(
@@
-496,19
+483,16
@@
describe('Abstract pool test suite', () => {
runTime: { median: true },
elu: { median: true }
})
runTime: { median: true },
elu: { median: true }
})
- expect(pool.workerChoiceStrategyContext.opts).toStrictEqual({
- retries: pool.info.maxSize,
- runTime: { median: true },
- waitTime: { median: false },
- elu: { median: true }
- })
for (const [, workerChoiceStrategy] of pool.workerChoiceStrategyContext
.workerChoiceStrategies) {
expect(workerChoiceStrategy.opts).toStrictEqual({
for (const [, workerChoiceStrategy] of pool.workerChoiceStrategyContext
.workerChoiceStrategies) {
expect(workerChoiceStrategy.opts).toStrictEqual({
- retries: pool.info.maxSize,
runTime: { median: true },
waitTime: { median: false },
runTime: { median: true },
waitTime: { median: false },
- elu: { median: true }
+ elu: { median: true },
+ weights: expect.objectContaining({
+ 0: expect.any(Number),
+ [pool.info.maxSize - 1]: expect.any(Number)
+ })
})
}
expect(
})
}
expect(
@@
-538,19
+522,16
@@
describe('Abstract pool test suite', () => {
runTime: { median: false },
elu: { median: false }
})
runTime: { median: false },
elu: { median: false }
})
- expect(pool.workerChoiceStrategyContext.opts).toStrictEqual({
- retries: pool.info.maxSize,
- runTime: { median: false },
- waitTime: { median: false },
- elu: { median: false }
- })
for (const [, workerChoiceStrategy] of pool.workerChoiceStrategyContext
.workerChoiceStrategies) {
expect(workerChoiceStrategy.opts).toStrictEqual({
for (const [, workerChoiceStrategy] of pool.workerChoiceStrategyContext
.workerChoiceStrategies) {
expect(workerChoiceStrategy.opts).toStrictEqual({
- retries: pool.info.maxSize,
runTime: { median: false },
waitTime: { median: false },
runTime: { median: false },
waitTime: { median: false },
- elu: { median: false }
+ elu: { median: false },
+ weights: expect.objectContaining({
+ 0: expect.any(Number),
+ [pool.info.maxSize - 1]: expect.any(Number)
+ })
})
}
expect(
})
}
expect(
@@
-723,6
+704,7
@@
describe('Abstract pool test suite', () => {
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+ strategyRetries: 0,
minSize: numberOfWorkers,
maxSize: numberOfWorkers,
workerNodes: numberOfWorkers,
minSize: numberOfWorkers,
maxSize: numberOfWorkers,
workerNodes: numberOfWorkers,
@@
-736,7
+718,7
@@
describe('Abstract pool test suite', () => {
pool = new DynamicClusterPool(
Math.floor(numberOfWorkers / 2),
numberOfWorkers,
pool = new DynamicClusterPool(
Math.floor(numberOfWorkers / 2),
numberOfWorkers,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
expect(pool.info).toStrictEqual({
version,
)
expect(pool.info).toStrictEqual({
version,
@@
-745,6
+727,7
@@
describe('Abstract pool test suite', () => {
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+ strategyRetries: 0,
minSize: Math.floor(numberOfWorkers / 2),
maxSize: numberOfWorkers,
workerNodes: Math.floor(numberOfWorkers / 2),
minSize: Math.floor(numberOfWorkers / 2),
maxSize: numberOfWorkers,
workerNodes: Math.floor(numberOfWorkers / 2),
@@
-760,7
+743,7
@@
describe('Abstract pool test suite', () => {
it('Verify that pool worker tasks usage are initialized', async () => {
const pool = new FixedClusterPool(
numberOfWorkers,
it('Verify that pool worker tasks usage are initialized', async () => {
const pool = new FixedClusterPool(
numberOfWorkers,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
for (const workerNode of pool.workerNodes) {
expect(workerNode).toBeInstanceOf(WorkerNode)
)
for (const workerNode of pool.workerNodes) {
expect(workerNode).toBeInstanceOf(WorkerNode)
@@
-796,7
+779,7
@@
describe('Abstract pool test suite', () => {
it('Verify that pool worker tasks queue are initialized', async () => {
let pool = new FixedClusterPool(
numberOfWorkers,
it('Verify that pool worker tasks queue are initialized', async () => {
let pool = new FixedClusterPool(
numberOfWorkers,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
for (const workerNode of pool.workerNodes) {
expect(workerNode).toBeInstanceOf(WorkerNode)
)
for (const workerNode of pool.workerNodes) {
expect(workerNode).toBeInstanceOf(WorkerNode)
@@
-822,7
+805,7
@@
describe('Abstract pool test suite', () => {
it('Verify that pool worker info are initialized', async () => {
let pool = new FixedClusterPool(
numberOfWorkers,
it('Verify that pool worker info are initialized', async () => {
let pool = new FixedClusterPool(
numberOfWorkers,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
for (const workerNode of pool.workerNodes) {
expect(workerNode).toBeInstanceOf(WorkerNode)
)
for (const workerNode of pool.workerNodes) {
expect(workerNode).toBeInstanceOf(WorkerNode)
@@
-830,7
+813,8
@@
describe('Abstract pool test suite', () => {
id: expect.any(Number),
type: WorkerTypes.cluster,
dynamic: false,
id: expect.any(Number),
type: WorkerTypes.cluster,
dynamic: false,
- ready: true
+ ready: true,
+ stealing: false
})
}
await pool.destroy()
})
}
await pool.destroy()
@@
-845,7
+829,8
@@
describe('Abstract pool test suite', () => {
id: expect.any(Number),
type: WorkerTypes.thread,
dynamic: false,
id: expect.any(Number),
type: WorkerTypes.thread,
dynamic: false,
- ready: true
+ ready: true,
+ stealing: false
})
}
await pool.destroy()
})
}
await pool.destroy()
@@
-872,15
+857,15
@@
describe('Abstract pool test suite', () => {
it('Verify that pool can be started after initialization', async () => {
const pool = new FixedClusterPool(
numberOfWorkers,
it('Verify that pool can be started after initialization', async () => {
const pool = new FixedClusterPool(
numberOfWorkers,
- './tests/worker-files/cluster/testWorker.js',
+ './tests/worker-files/cluster/testWorker.
c
js',
{
startWorkers: false
}
)
expect(pool.info.started).toBe(false)
expect(pool.info.ready).toBe(false)
{
startWorkers: false
}
)
expect(pool.info.started).toBe(false)
expect(pool.info.ready).toBe(false)
- expect(pool.readyEventEmitted).toBe(false)
expect(pool.workerNodes).toStrictEqual([])
expect(pool.workerNodes).toStrictEqual([])
+ expect(pool.readyEventEmitted).toBe(false)
await expect(pool.execute()).rejects.toThrow(
new Error('Cannot execute a task on not started pool')
)
await expect(pool.execute()).rejects.toThrow(
new Error('Cannot execute a task on not started pool')
)
@@
-899,7
+884,7
@@
describe('Abstract pool test suite', () => {
it('Verify that pool execute() arguments are checked', async () => {
const pool = new FixedClusterPool(
numberOfWorkers,
it('Verify that pool execute() arguments are checked', async () => {
const pool = new FixedClusterPool(
numberOfWorkers,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
await expect(pool.execute(undefined, 0)).rejects.toThrow(
new TypeError('name argument must be a string')
)
await expect(pool.execute(undefined, 0)).rejects.toThrow(
new TypeError('name argument must be a string')
@@
-922,7
+907,7
@@
describe('Abstract pool test suite', () => {
it('Verify that pool worker tasks usage are computed', async () => {
const pool = new FixedClusterPool(
numberOfWorkers,
it('Verify that pool worker tasks usage are computed', async () => {
const pool = new FixedClusterPool(
numberOfWorkers,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
const promises = new Set()
const maxMultiplier = 2
)
const promises = new Set()
const maxMultiplier = 2
@@
-1073,7
+1058,7
@@
describe('Abstract pool test suite', () => {
const pool = new DynamicClusterPool(
Math.floor(numberOfWorkers / 2),
numberOfWorkers,
const pool = new DynamicClusterPool(
Math.floor(numberOfWorkers / 2),
numberOfWorkers,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
expect(pool.emitter.eventNames()).toStrictEqual([])
let poolInfo
)
expect(pool.emitter.eventNames()).toStrictEqual([])
let poolInfo
@@
-1092,6
+1077,7
@@
describe('Abstract pool test suite', () => {
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+ strategyRetries: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
@@
-1132,6
+1118,7
@@
describe('Abstract pool test suite', () => {
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+ strategyRetries: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
@@
-1171,6
+1158,7
@@
describe('Abstract pool test suite', () => {
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+ strategyRetries: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
@@
-1213,10
+1201,12
@@
describe('Abstract pool test suite', () => {
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
started: true,
ready: true,
strategy: WorkerChoiceStrategies.ROUND_ROBIN,
+ strategyRetries: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
idleWorkerNodes: expect.any(Number),
minSize: expect.any(Number),
maxSize: expect.any(Number),
workerNodes: expect.any(Number),
idleWorkerNodes: expect.any(Number),
+ stealingWorkerNodes: expect.any(Number),
busyWorkerNodes: expect.any(Number),
executedTasks: expect.any(Number),
executingTasks: expect.any(Number),
busyWorkerNodes: expect.any(Number),
executedTasks: expect.any(Number),
executingTasks: expect.any(Number),
@@
-1226,7
+1216,7
@@
describe('Abstract pool test suite', () => {
stolenTasks: expect.any(Number),
failedTasks: expect.any(Number)
})
stolenTasks: expect.any(Number),
failedTasks: expect.any(Number)
})
- expect(pool.hasBackPressure.callCount).toBe
(5
)
+ expect(pool.hasBackPressure.callCount).toBe
GreaterThanOrEqual(7
)
await pool.destroy()
})
await pool.destroy()
})
@@
-1254,9
+1244,9
@@
describe('Abstract pool test suite', () => {
const startTime = performance.now()
await pool.destroy()
const elapsedTime = performance.now() - startTime
const startTime = performance.now()
await pool.destroy()
const elapsedTime = performance.now() - startTime
- expect(tasksFinished).toBe(numberOfWorkers * maxMultiplier)
+ expect(tasksFinished).toBe
LessThanOrEqual
(numberOfWorkers * maxMultiplier)
expect(elapsedTime).toBeGreaterThanOrEqual(2000)
expect(elapsedTime).toBeGreaterThanOrEqual(2000)
- expect(elapsedTime).toBeLessThanOrEqual(tasksFinishedTimeout +
1
00)
+ expect(elapsedTime).toBeLessThanOrEqual(tasksFinishedTimeout +
8
00)
})
it('Verify that destroy() waits until the tasks finished timeout is reached', async () => {
})
it('Verify that destroy() waits until the tasks finished timeout is reached', async () => {
@@
-1284,7
+1274,7
@@
describe('Abstract pool test suite', () => {
await pool.destroy()
const elapsedTime = performance.now() - startTime
expect(tasksFinished).toBe(0)
await pool.destroy()
const elapsedTime = performance.now() - startTime
expect(tasksFinished).toBe(0)
- expect(elapsedTime).toBeLessThanOrEqual(tasksFinishedTimeout +
6
00)
+ expect(elapsedTime).toBeLessThanOrEqual(tasksFinishedTimeout +
8
00)
})
it('Verify that pool asynchronous resource track tasks execution', async () => {
})
it('Verify that pool asynchronous resource track tasks execution', async () => {
@@
-1341,7
+1331,7
@@
describe('Abstract pool test suite', () => {
await dynamicThreadPool.destroy()
const fixedClusterPool = new FixedClusterPool(
numberOfWorkers,
await dynamicThreadPool.destroy()
const fixedClusterPool = new FixedClusterPool(
numberOfWorkers,
- './tests/worker-files/cluster/testMultipleTaskFunctionsWorker.js'
+ './tests/worker-files/cluster/testMultipleTaskFunctionsWorker.
c
js'
)
await waitPoolEvents(fixedClusterPool, PoolEvents.ready, 1)
expect(fixedClusterPool.hasTaskFunction(DEFAULT_TASK_NAME)).toBe(true)
)
await waitPoolEvents(fixedClusterPool, PoolEvents.ready, 1)
expect(fixedClusterPool.hasTaskFunction(DEFAULT_TASK_NAME)).toBe(true)
@@
-1481,7
+1471,7
@@
describe('Abstract pool test suite', () => {
await dynamicThreadPool.destroy()
const fixedClusterPool = new FixedClusterPool(
numberOfWorkers,
await dynamicThreadPool.destroy()
const fixedClusterPool = new FixedClusterPool(
numberOfWorkers,
- './tests/worker-files/cluster/testMultipleTaskFunctionsWorker.js'
+ './tests/worker-files/cluster/testMultipleTaskFunctionsWorker.
c
js'
)
await waitPoolEvents(fixedClusterPool, PoolEvents.ready, 1)
expect(fixedClusterPool.listTaskFunctionNames()).toStrictEqual([
)
await waitPoolEvents(fixedClusterPool, PoolEvents.ready, 1)
expect(fixedClusterPool.listTaskFunctionNames()).toStrictEqual([
@@
-1551,7
+1541,7
@@
describe('Abstract pool test suite', () => {
const pool = new DynamicClusterPool(
Math.floor(numberOfWorkers / 2),
numberOfWorkers,
const pool = new DynamicClusterPool(
Math.floor(numberOfWorkers / 2),
numberOfWorkers,
- './tests/worker-files/cluster/testMultipleTaskFunctionsWorker.js'
+ './tests/worker-files/cluster/testMultipleTaskFunctionsWorker.
c
js'
)
const data = { n: 10 }
const result0 = await pool.execute(data)
)
const data = { n: 10 }
const result0 = await pool.execute(data)
@@
-1616,17
+1606,12
@@
describe('Abstract pool test suite', () => {
const pool = new DynamicClusterPool(
Math.floor(numberOfWorkers / 2),
numberOfWorkers,
const pool = new DynamicClusterPool(
Math.floor(numberOfWorkers / 2),
numberOfWorkers,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
const workerNodeKey = 0
await expect(
pool.sendKillMessageToWorker(workerNodeKey)
).resolves.toBeUndefined()
)
const workerNodeKey = 0
await expect(
pool.sendKillMessageToWorker(workerNodeKey)
).resolves.toBeUndefined()
- await expect(
- pool.sendKillMessageToWorker(numberOfWorkers)
- ).rejects.toStrictEqual(
- new Error(`Invalid worker node key '${numberOfWorkers}'`)
- )
await pool.destroy()
})
await pool.destroy()
})
@@
-1634,7
+1619,7
@@
describe('Abstract pool test suite', () => {
const pool = new DynamicClusterPool(
Math.floor(numberOfWorkers / 2),
numberOfWorkers,
const pool = new DynamicClusterPool(
Math.floor(numberOfWorkers / 2),
numberOfWorkers,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
const workerNodeKey = 0
await expect(
)
const workerNodeKey = 0
await expect(
@@
-1654,7
+1639,7
@@
describe('Abstract pool test suite', () => {
const pool = new DynamicClusterPool(
Math.floor(numberOfWorkers / 2),
numberOfWorkers,
const pool = new DynamicClusterPool(
Math.floor(numberOfWorkers / 2),
numberOfWorkers,
- './tests/worker-files/cluster/testWorker.js'
+ './tests/worker-files/cluster/testWorker.
c
js'
)
await expect(
pool.sendTaskFunctionOperationToWorkers({
)
await expect(
pool.sendTaskFunctionOperationToWorkers({