Skip to content

Commit 83b2a38

Browse files
committed
Fix a block manager change, and a typo
Signed-off-by: Graham King <[email protected]>
1 parent 27f1c6f commit 83b2a38

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

lib/llm/src/block_manager/pool.rs

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
pub mod managed;
55
pub use managed::ManagedBlockPool;
66

7+
use anyhow::Result;
78
use derive_builder::Builder;
89
use derive_getters::Dissolve;
910
use serde::{Deserialize, Serialize};
@@ -31,8 +32,6 @@ use tokio::runtime::Handle;
3132
use tokio::sync::oneshot;
3233
use tokio_util::sync::CancellationToken;
3334

34-
use dynamo_runtime::Result;
35-
3635
// Type aliases to reduce complexity across the module
3736
type BlockPoolResult<T> = Result<T, BlockPoolError>;
3837
type AsyncResponse<T> = Result<oneshot::Receiver<T>, BlockPoolError>;

lib/runtime/src/transports/zmq.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -217,7 +217,7 @@ impl Server {
217217
mpsc::error::TrySendError::Full(data) => {
218218
tracing::warn!(
219219
request_id,
220-
"response stream is full; backpressue alert"
220+
"response stream is full; backpressure alert"
221221
);
222222
// todo - add timeout - we are blocking all other streams
223223
if (tx.send(data).await).is_err() {

0 commit comments

Comments
 (0)