+ workerUsage.runTime.history.push(message.taskPerformance.runTime)
+ workerUsage.runTime.median = median(workerUsage.runTime.history)
+ }
+ }
+ }
+
+ private updateWaitTimeWorkerUsage (
+ workerUsage: WorkerUsage,
+ task: Task<Data>
+ ): void {
+ const timestamp = performance.now()
+ const taskWaitTime = timestamp - (task.timestamp ?? timestamp)
+ if (
+ this.workerChoiceStrategyContext.getTaskStatisticsRequirements().waitTime
+ .aggregate
+ ) {
+ workerUsage.waitTime.aggregate += taskWaitTime ?? 0
+ if (
+ this.workerChoiceStrategyContext.getTaskStatisticsRequirements()
+ .waitTime.average &&
+ workerUsage.tasks.executed !== 0
+ ) {
+ workerUsage.waitTime.average =
+ workerUsage.waitTime.aggregate / workerUsage.tasks.executed
+ }
+ if (
+ this.workerChoiceStrategyContext.getTaskStatisticsRequirements()
+ .waitTime.median &&
+ taskWaitTime != null
+ ) {
+ workerUsage.waitTime.history.push(taskWaitTime)
+ workerUsage.waitTime.median = median(workerUsage.waitTime.history)
+ }
+ }
+ }
+
+ private updateEluWorkerUsage (
+ workerTasksUsage: WorkerUsage,
+ message: MessageValue<Response>
+ ): void {
+ if (this.workerChoiceStrategyContext.getTaskStatisticsRequirements().elu) {
+ if (
+ workerTasksUsage.elu != null &&
+ message.taskPerformance?.elu != null
+ ) {
+ workerTasksUsage.elu = {
+ idle: workerTasksUsage.elu.idle + message.taskPerformance.elu.idle,
+ active:
+ workerTasksUsage.elu.active + message.taskPerformance.elu.active,
+ utilization:
+ (workerTasksUsage.elu.utilization +
+ message.taskPerformance.elu.utilization) /
+ 2
+ }
+ } else if (message.taskPerformance?.elu != null) {
+ workerTasksUsage.elu = message.taskPerformance.elu