medRunTime: true
}
)
- expect(workerChoiceStrategyContext.getRequiredStatistics().avgRunTime).toBe(
- false
- )
- expect(workerChoiceStrategyContext.getRequiredStatistics().medRunTime).toBe(
- true
- )
- workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
- dynamicPool,
- wwrWorkerChoiceStrategy,
- {
- medRunTime: true
- }
- )
- expect(workerChoiceStrategyContext.getRequiredStatistics().avgRunTime).toBe(
- false
- )
- expect(workerChoiceStrategyContext.getRequiredStatistics().medRunTime).toBe(
- true
- )
- const fsWorkerChoiceStrategy = WorkerChoiceStrategies.FAIR_SHARE
- workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
- fixedPool,
- fsWorkerChoiceStrategy,
- {
- medRunTime: true
- }
- )
- expect(workerChoiceStrategyContext.getRequiredStatistics().avgRunTime).toBe(
- false
- )
- expect(workerChoiceStrategyContext.getRequiredStatistics().medRunTime).toBe(
- true
- )
- workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
- dynamicPool,
- fsWorkerChoiceStrategy,
- {
- medRunTime: true
- }
- )
- expect(workerChoiceStrategyContext.getRequiredStatistics().avgRunTime).toBe(
- false
- )
- expect(workerChoiceStrategyContext.getRequiredStatistics().medRunTime).toBe(
- true
- )
- })
-
- it('Verify that worker choice strategy options enable median wait time pool statistics', () => {
- const wwrWorkerChoiceStrategy = WorkerChoiceStrategies.WEIGHTED_ROUND_ROBIN
- let workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
- fixedPool,
- wwrWorkerChoiceStrategy,
- {
- medWaitTime: true
- }
- )
expect(
- workerChoiceStrategyContext.getRequiredStatistics().avgWaitTime
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().avgRunTime
).toBe(false)
expect(
- workerChoiceStrategyContext.getRequiredStatistics().medWaitTime
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().medRunTime
).toBe(true)
workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool,
wwrWorkerChoiceStrategy,
{
- medWaitTime: true
+ medRunTime: true
}
)
expect(
- workerChoiceStrategyContext.getRequiredStatistics().avgWaitTime
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().avgRunTime
).toBe(false)
expect(
- workerChoiceStrategyContext.getRequiredStatistics().medWaitTime
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().medRunTime
).toBe(true)
const fsWorkerChoiceStrategy = WorkerChoiceStrategies.FAIR_SHARE
workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
fixedPool,
fsWorkerChoiceStrategy,
{
- medWaitTime: true
+ medRunTime: true
}
)
expect(
- workerChoiceStrategyContext.getRequiredStatistics().avgWaitTime
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().avgRunTime
).toBe(false)
expect(
- workerChoiceStrategyContext.getRequiredStatistics().medWaitTime
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().medRunTime
).toBe(true)
workerChoiceStrategyContext = new WorkerChoiceStrategyContext(
dynamicPool,
fsWorkerChoiceStrategy,
{
- medWaitTime: true
+ medRunTime: true
}
)
expect(
- workerChoiceStrategyContext.getRequiredStatistics().avgWaitTime
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().avgRunTime
).toBe(false)
expect(
- workerChoiceStrategyContext.getRequiredStatistics().medWaitTime
+ workerChoiceStrategyContext.getTaskStatisticsRequirements().medRunTime
).toBe(true)
})
})