Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
| Version | Supported |
| ------- | ------------------ |
-| 4.x.x | :white_check_mark: |
+| 5.x.x | :white_check_mark: |
+| 4.x.x | :x: |
| 3.x.x | :x: |
| 2.x.x | :x: |
| 1.x.x | :x: |
private async sendKillMessageToWorker (
workerNodeKey: number,
- timeout = 2000
+ timeout = 1000
): Promise<void> {
let timeoutHandle: NodeJS.Timeout | undefined
let killMessageListener:
const elapsedTime = performance.now() - startTime
expect(tasksFinished).toBeLessThanOrEqual(numberOfWorkers * maxMultiplier)
expect(elapsedTime).toBeGreaterThanOrEqual(2000)
- expect(elapsedTime).toBeLessThanOrEqual(tasksFinishedTimeout + 800)
+ // Worker kill message response timeout is 1000ms
+ expect(elapsedTime).toBeLessThanOrEqual(
+ tasksFinishedTimeout + 1000 * tasksFinished + 100
+ )
})
it('Verify that destroy() waits until the tasks finished timeout is reached', async () => {