executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
threadWorkerNode.tasksQueue.size
)
expect(threadWorkerNode.onBackPressureStarted).toBe(false)
- expect(threadWorkerNode.onIdleWorkerNodeCount).toBe(0)
expect(threadWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
expect(clusterWorkerNode).toBeInstanceOf(WorkerNode)
executing: 0,
queued: 0,
maxQueued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
clusterWorkerNode.tasksQueue.size
)
expect(clusterWorkerNode.onBackPressureStarted).toBe(false)
- expect(clusterWorkerNode.onIdleWorkerNodeCount).toBe(0)
expect(clusterWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
})
executed: 0,
executing: 0,
queued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
executed: 0,
executing: 0,
queued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},
executed: 0,
executing: 0,
queued: 0,
+ sequentiallyStolen: 0,
stolen: 0,
failed: 0
},