)
let results = new Set()
for (let i = 0; i < max; i++) {
- results.add(pool.workerNodes[pool.chooseWorkerNode()].worker.id)
+ results.add(pool.workerNodes[pool.chooseWorkerNode()].info.id)
}
expect(results.size).toBe(max)
await pool.destroy()
)
results = new Set()
for (let i = 0; i < max; i++) {
- results.add(pool.workerNodes[pool.chooseWorkerNode()].worker.threadId)
+ results.add(pool.workerNodes[pool.chooseWorkerNode()].info.id)
}
expect(results.size).toBe(max)
await pool.destroy()
'./tests/worker-files/thread/testWorker.mjs',
{ workerChoiceStrategy: 'UNKNOWN_STRATEGY' }
)
- ).toThrowError("Invalid worker choice strategy 'UNKNOWN_STRATEGY'")
+ ).toThrow("Invalid worker choice strategy 'UNKNOWN_STRATEGY'")
})
})