diff --git a/src/transport/middle_proxy/health.rs b/src/transport/middle_proxy/health.rs
index e56d001..000bca0 100644
--- a/src/transport/middle_proxy/health.rs
+++ b/src/transport/middle_proxy/health.rs
@@ -383,8 +383,7 @@ async fn check_family(
     let reconnect_budget = health_reconnect_budget(pool, dc_endpoints.len());
     let reconnect_sem = Arc::new(Semaphore::new(reconnect_budget));
 
-    if pool.floor_mode() == MeFloorMode::Static {
-    }
+    if pool.floor_mode() == MeFloorMode::Static {}
 
     let mut live_addr_counts = HashMap::<(i32, SocketAddr), usize>::new();
     let mut live_writer_ids_by_addr = HashMap::<(i32, SocketAddr), Vec<u64>>::new();
@@ -617,7 +616,8 @@ async fn check_family(
                         continue;
                     }
 
-                    let base_req = pool_for_reconnect.required_writers_for_dc_with_floor_mode(endpoints_for_dc.len(), false);
+                    let base_req = pool_for_reconnect
+                        .required_writers_for_dc_with_floor_mode(endpoints_for_dc.len(), false);
                     if alive + restored >= base_req {
                         pool_for_reconnect
                             .stats
diff --git a/src/transport/middle_proxy/pool.rs b/src/transport/middle_proxy/pool.rs
index 315b6fc..b89a844 100644
--- a/src/transport/middle_proxy/pool.rs
+++ b/src/transport/middle_proxy/pool.rs
@@ -1670,7 +1670,8 @@ impl MePool {
                 }
 
                 if endpoints_len > 0 {
-                    let base_req = self.required_writers_for_dc_with_floor_mode(endpoints_len, false);
+                    let base_req =
+                        self.required_writers_for_dc_with_floor_mode(endpoints_len, false);
                     let active_for_dc = {
                         let ws = self.writers.read().await;
                         ws.iter()