Skip to content

Commit a3f61a0

Browse files
committed
fix GetPodScores
Signed-off-by: sagiahrac <[email protected]> Signed-off-by: Sage Ahrac <[email protected]>
1 parent 8d2b16c commit a3f61a0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

pkg/kvcache/indexer.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -133,15 +133,15 @@ func (k *Indexer) GetPodScores(ctx context.Context, prompt, modelName string,
133133
traceLogger.Info("found tokens", "tokens", tokens, "block-keys", blockKeys)
134134

135135
// 3. query kvblock indexer for pods
136-
strBlockKeys, keyToPods, err := k.kvBlockIndex.Lookup(ctx, blockKeys, sets.New(podIdentifiers...))
136+
keyToPods, err := k.kvBlockIndex.Lookup(ctx, blockKeys, sets.New(podIdentifiers...))
137137
if err != nil {
138138
return nil, fmt.Errorf("failed to query kvblock indexer: %w", err)
139139
}
140140
traceLogger.Info("found block keys", "block-keys", blockKeys,
141141
"pods", podsPerKeyPrintHelper(keyToPods))
142142

143143
// 4. score pods
144-
podScores, err := k.kvBlockScorer.Score(strBlockKeys, keyToPods)
144+
podScores, err := k.kvBlockScorer.Score(blockKeys, keyToPods)
145145
if err != nil {
146146
return nil, fmt.Errorf("failed to query kvblock scorer: %w", err)
147147
}

0 commit comments

Comments
 (0)