medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
pool.setWorkerChoiceStrategyOptions({ medRunTime: true })
expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
medRunTime: true,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
pool.setWorkerChoiceStrategyOptions({ medRunTime: false })
expect(pool.opts.workerChoiceStrategyOptions).toStrictEqual({
medRunTime: false,
waitTime: false,
avgWaitTime: false,
- medWaitTime: false
+ medWaitTime: false,
+ elu: false
})
await pool.destroy()
})
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
}
await pool.destroy()
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
}
await Promise.all(promises)
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
}
await pool.destroy()
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
expect(workerNode.tasksUsage.ran).toBeGreaterThan(0)
expect(workerNode.tasksUsage.ran).toBeLessThanOrEqual(maxMultiplier)
waitTimeHistory: expect.any(CircularArray),
avgWaitTime: 0,
medWaitTime: 0,
- error: 0
+ error: 0,
+ elu: undefined
})
expect(workerNode.tasksUsage.runTimeHistory.length).toBe(0)
expect(workerNode.tasksUsage.waitTimeHistory.length).toBe(0)