const { version } = require('../../../package.json')
const { waitPoolEvents } = require('../../test-utils')
const { version } = require('../../../package.json')
const { waitPoolEvents } = require('../../test-utils')
})
pool.enableTasksQueue(true, { concurrency: 2 })
expect(pool.opts.enableTasksQueue).toBe(true)
expect(pool.opts.tasksQueueOptions).toStrictEqual({
concurrency: 2,
})
pool.enableTasksQueue(true, { concurrency: 2 })
expect(pool.opts.enableTasksQueue).toBe(true)
expect(pool.opts.tasksQueueOptions).toStrictEqual({
concurrency: 2,
expect(() => pool.setTasksQueueOptions({ concurrency: 0.2 })).toThrowError(
new TypeError('Invalid worker node tasks concurrency: must be an integer')
)
expect(() => pool.setTasksQueueOptions({ concurrency: 0.2 })).toThrowError(
new TypeError('Invalid worker node tasks concurrency: must be an integer')
)
maxQueuedTasks: expect.any(Number),
queuedTasks: expect.any(Number),
backPressure: true,
maxQueuedTasks: expect.any(Number),
queuedTasks: expect.any(Number),
backPressure: true,
executed: expect.any(Number),
executing: expect.any(Number),
failed: 0,
executed: expect.any(Number),
executing: expect.any(Number),
failed: 0,