This commit is contained in:
Nicolas Patry 2024-01-11 17:57:31 +01:00
parent ca04548080
commit a38d701911

View File

@ -115,7 +115,7 @@ impl Infer {
// MPSC channel to communicate with the background batching task
let (response_tx, response_rx) = mpsc::unbounded_channel();
let _input_length = valid_request.input_length;
let input_length = valid_request.input_length;
// Append the request to the queue
self.queue.append(Entry {
@ -148,7 +148,7 @@ impl Infer {
let use_top_tokens = request.parameters.top_n_tokens.is_some_and(|x| x > 0);
// Create stream and keep semaphore permit as long as generate lives
let (_permit, input_length, mut stream) = self.generate_stream(request).await?;
let (_permit, _input_length, mut stream) = self.generate_stream(request).await?;
// Return values
let mut result_prefill = Vec::new();