+ for (const workerNode of this.workerNodes) {
+ this.setWorkerNodeTasksUsage(workerNode, {
+ tasks: {
+ executed: 0,
+ executing: 0,
+ queued:
+ this.opts.enableTasksQueue === true
+ ? workerNode.tasksQueue.size
+ : 0,
+ failed: 0
+ },
+ runTime: {
+ aggregation: 0,
+ average: 0,
+ median: 0,
+ history: new CircularArray()
+ },
+ waitTime: {
+ aggregation: 0,
+ average: 0,
+ median: 0,
+ history: new CircularArray()
+ },
+ elu: undefined
+ })
+ this.setWorkerStatistics(workerNode.worker)
+ }