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 c376619 commit f9dc844Copy full SHA for f9dc844
lib/llm/src/kv_router.rs
@@ -142,7 +142,10 @@ impl KvRouter {
142
.map(|block| LocalBlockHash(block.block_hash()))
143
.collect();
144
let overlap_scores = self.indexer.find_matches(local_block_hashes).await?;
145
- let worker_id = self.scheduler.schedule(overlap_scores.clone(), isl_tokens).await?;
+ let worker_id = self
146
+ .scheduler
147
+ .schedule(overlap_scores.clone(), isl_tokens)
148
+ .await?;
149
let overlap_amount = overlap_scores.scores.get(&worker_id).copied().unwrap_or(0);
150
Ok((worker_id, overlap_amount))
151
}
0 commit comments