@@ -166,7 +166,9 @@ func (p *SchedulerProfile) runFilterPlugins(ctx context.Context, request *types.
166
166
}
167
167
168
168
func (p * SchedulerProfile ) runScorerPlugins (ctx context.Context , request * types.LLMRequest , cycleState * types.CycleState , pods []types.Pod ) map [types.Pod ]float64 {
169
- loggerDebug := log .FromContext (ctx ).V (logutil .DEBUG )
169
+ logger := log .FromContext (ctx )
170
+ loggerTrace := logger .V (logutil .TRACE )
171
+ loggerDebug := logger .V (logutil .DEBUG )
170
172
loggerDebug .Info ("Before running scorer plugins" , "pods" , pods )
171
173
172
174
weightedScorePerPod := make (map [types.Pod ]float64 , len (pods ))
@@ -180,6 +182,9 @@ func (p *SchedulerProfile) runScorerPlugins(ctx context.Context, request *types.
180
182
scores := scorer .Score (ctx , cycleState , request , pods )
181
183
metrics .RecordPluginProcessingLatency (ScorerExtensionPoint , scorer .TypedName ().Type , scorer .TypedName ().Name , time .Since (before ))
182
184
for pod , score := range scores { // weight is relative to the sum of weights
185
+ if loggerTrace .Enabled () {
186
+ loggerTrace .Info ("calculated score" , "plugin" , scorer .TypedName (), "endpoint" , pod .GetPod ().NamespacedName , "score" , score )
187
+ }
183
188
weightedScorePerPod [pod ] += enforceScoreRange (score ) * float64 (scorer .Weight ())
184
189
}
185
190
loggerDebug .Info ("Completed running scorer plugin successfully" , "plugin" , scorer .TypedName ())
0 commit comments