+ this.workerChoiceStrategyContext.getTaskStatistics().medWaitTime &&
+ message.taskPerformance?.waitTime != null
+ ) {
+ workerUsage.waitTime.history.push(message.taskPerformance.waitTime)
+ workerUsage.waitTime.median = median(workerUsage.waitTime.history)
+ }
+ }
+ }
+
+ private updateEluWorkerUsage (
+ workerTasksUsage: WorkerUsage,
+ message: MessageValue<Response>
+ ): void {
+ if (this.workerChoiceStrategyContext.getTaskStatistics().elu) {
+ if (
+ workerTasksUsage.elu != null &&
+ message.taskPerformance?.elu != null