it('Verify scale thread up and down is working', async () => {
expect(pool.workerNodes.length).toBe(min)
- for (let i = 0; i < max * 10; i++) {
+ for (let i = 0; i < max * 2; i++) {
pool.execute()
}
expect(pool.workerNodes.length).toBe(max)
await TestUtils.waitExits(pool, max - min)
expect(pool.workerNodes.length).toBe(min)
- for (let i = 0; i < max * 10; i++) {
+ for (let i = 0; i < max * 2; i++) {
pool.execute()
}
expect(pool.workerNodes.length).toBe(max)
}
)
expect(longRunningPool.workerNodes.length).toBe(min)
- for (let i = 0; i < max * 10; i++) {
+ for (let i = 0; i < max * 2; i++) {
longRunningPool.execute()
}
expect(longRunningPool.workerNodes.length).toBe(max)
}
)
expect(longRunningPool.workerNodes.length).toBe(min)
- for (let i = 0; i < max * 10; i++) {
+ for (let i = 0; i < max * 2; i++) {
longRunningPool.execute()
}
expect(longRunningPool.workerNodes.length).toBe(max)