Skip to content

Commit 0771f47

Browse files
committed
fix: safe access to tasks queue size
Signed-off-by: Jérôme Benoit <[email protected]>
1 parent c620e5f commit 0771f47

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

src/pools/abstract-pool.ts

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2448,7 +2448,11 @@ export abstract class AbstractPool<
24482448
}
24492449

24502450
private tasksQueueSize(workerNodeKey: number): number {
2451-
return this.workerNodes[workerNodeKey].tasksQueueSize()
2451+
const workerNode = this.workerNodes[workerNodeKey]
2452+
if (workerNode == null) {
2453+
return 0
2454+
}
2455+
return workerNode.tasksQueueSize()
24522456
}
24532457

24542458
protected flushTasksQueue(workerNodeKey: number): number {

0 commit comments

Comments
 (0)