expect(pool.workerNodes.length).toBe(min)
})
- it('Shutdown test', async () => {
+ it('Shutdown test', { retry: 0 }, async ({ skip }) => {
+ if (process.env.CI) {
+ skip()
+ return
+ }
const exitPromise = waitWorkerEvents(pool, 'exit', min)
expect(pool.emitter.eventNames()).toStrictEqual([PoolEvents.busy])
let poolDestroy = 0
expect(error.stack).toBeDefined()
})
- it('Shutdown test', async () => {
+ it('Shutdown test', { retry: 0 }, async ({ skip }) => {
+ if (process.env.CI) {
+ skip()
+ return
+ }
const exitPromise = waitWorkerEvents(pool, 'exit', numberOfWorkers)
expect(pool.emitter.eventNames()).toStrictEqual([])
let poolDestroy = 0
expect(pool.workerNodes.length).toBe(min)
})
- it('Shutdown test', async () => {
+ it('Shutdown test', { retry: 0 }, async ({ skip }) => {
+ if (process.env.CI) {
+ skip()
+ return
+ }
const exitPromise = waitWorkerEvents(pool, 'exit', min)
expect(pool.emitter.eventNames()).toStrictEqual([PoolEvents.busy])
let poolDestroy = 0
expect(error.stack).toBeDefined()
})
- it('Shutdown test', async () => {
+ it('Shutdown test', { retry: 0 }, async ({ skip }) => {
+ if (process.env.CI) {
+ skip()
+ return
+ }
const exitPromise = waitWorkerEvents(pool, 'exit', numberOfThreads)
expect(pool.emitter.eventNames()).toStrictEqual([])
let poolDestroy = 0