We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 47c1641 commit faedc88Copy full SHA for faedc88
cmd/epp/runner/runner.go
@@ -272,8 +272,8 @@ func (r *Runner) initializeScheduler(datastore datastore.Datastore) (*scheduling
272
kvCacheScorerWeight := envutil.GetEnvInt("KV_CACHE_SCORE_WEIGHT", scorer.DefaultKVCacheScorerWeight, setupLog)
273
274
schedulerProfile := framework.NewSchedulerProfile().
275
- WithScorers(framework.NewWeightedScorer(&scorer.QueueScorer{}, queueScorerWeight),
276
- framework.NewWeightedScorer(&scorer.KVCacheScorer{}, kvCacheScorerWeight)).
+ WithScorers(framework.NewWeightedScorer(scorer.NewQueueScorer(), queueScorerWeight),
+ framework.NewWeightedScorer(scorer.NewKVCacheScorer(), kvCacheScorerWeight)).
277
WithPicker(picker.NewMaxScorePicker())
278
279
if prefixCacheScheduling {
0 commit comments