fmt

Author: ziqifan617

lib/bindings/python/rust/llm/block_manager/vllm/connector/leader.rs

@@ -14,8 +14,8 @@ use crate::llm::block_manager::{
     distributed::KvbmLeader as PyKvbmLeader, vllm::connector::leader::slot::VllmConnectorSlot,
     vllm::KvbmRequest, VllmBlockManager,
 };
-use dynamo_runtime::metrics::prometheus_names::kvbm_connector_namespace;
 use crate::DistributedRuntime as PyDistributedRuntime;
+use dynamo_runtime::metrics::prometheus_names::kvbm_connector_namespace;
 
 use dynamo_llm::block_manager::{
     block::{
@@ -103,7 +103,9 @@ impl KvConnectorLeader {
         // if we need a drt, get it from here
         let drt = drt.inner().clone();
 
-        let ns = drt.namespace(kvbm_connector_namespace::KVBM_CONNECTOR_LEADER).unwrap();
+        let ns = drt
+            .namespace(kvbm_connector_namespace::KVBM_CONNECTOR_LEADER)
+            .unwrap();
 
         let kvbm_metrics = KvbmMetrics::new(&ns);
 

lib/bindings/python/rust/llm/block_manager/vllm/connector/worker.rs

@@ -12,11 +12,11 @@ use std::sync::{Arc, OnceLock};
 
 use super::*;
 use crate::llm::block_manager::distributed::get_barrier_id;
-use dynamo_runtime::metrics::prometheus_names::kvbm_connector_namespace;
 use crate::{
     llm::block_manager::distributed::VllmTensor, to_pyerr,
     DistributedRuntime as PyDistributedRuntime,
 };
+use dynamo_runtime::metrics::prometheus_names::kvbm_connector_namespace;
 
 use anyhow;
 use dynamo_llm::block_manager::distributed::{KvbmWorker, KvbmWorkerConfig};
@@ -92,7 +92,10 @@ impl KvConnectorWorker {
         )?
         .detach();
 
-        let kvbm_metrics = KvbmMetrics::new(&drt.namespace(kvbm_connector_namespace::KVBM_CONNECTOR_WORKER).unwrap());
+        let kvbm_metrics = KvbmMetrics::new(
+            &drt.namespace(kvbm_connector_namespace::KVBM_CONNECTOR_WORKER)
+                .unwrap(),
+        );
 
         tracing::info!(
             "KvConnectorWorker initialized with worker_id: {}",