diff --git a/pgxn/neon/communicator/src/backend_interface.rs b/pgxn/neon/communicator/src/backend_interface.rs
index 6b2748750f..e69a3749a6 100644
--- a/pgxn/neon/communicator/src/backend_interface.rs
+++ b/pgxn/neon/communicator/src/backend_interface.rs
@@ -254,9 +254,7 @@ pub unsafe extern "C" fn bcomm_cache_iterate_next(
 
 #[allow(clippy::missing_safety_doc)]
 #[unsafe(no_mangle)]
-pub unsafe extern "C" fn bcomm_cache_get_num_pages_used(
-    bs: &mut CommunicatorBackendStruct,
-) -> u64 {
+pub unsafe extern "C" fn bcomm_cache_get_num_pages_used(bs: &mut CommunicatorBackendStruct) -> u64 {
     bs.integrated_cache.get_num_buckets_in_use() as u64
 }
 
diff --git a/pgxn/neon/communicator/src/worker_process/main_loop.rs b/pgxn/neon/communicator/src/worker_process/main_loop.rs
index ec07cf61e5..9622849b5f 100644
--- a/pgxn/neon/communicator/src/worker_process/main_loop.rs
+++ b/pgxn/neon/communicator/src/worker_process/main_loop.rs
@@ -116,10 +116,9 @@ pub(super) fn init(
     file_cache_path: Option<PathBuf>,
 ) -> Result<&'static CommunicatorWorkerProcessStruct<'static>, String> {
     // The caller validated these already
-    let tenant_id = TenantId::from_str(tenant_id)
-        .map_err(|e| format!("invalid tenant ID: {e}"))?;
-    let timeline_id = TimelineId::from_str(timeline_id)
-        .map_err(|e| format!("invalid timeline ID: {e}"))?;
+    let tenant_id = TenantId::from_str(tenant_id).map_err(|e| format!("invalid tenant ID: {e}"))?;
+    let timeline_id =
+        TimelineId::from_str(timeline_id).map_err(|e| format!("invalid timeline ID: {e}"))?;
     let shard_spec =
         ShardSpec::new(shard_map, stripe_size).map_err(|e| format!("invalid shard spec: {e}:"))?;
 
@@ -363,7 +362,8 @@ impl<'t> CommunicatorWorkerProcessStruct<'t> {
                 };
 
                 let read_lsn = self.request_lsns(not_modified_since);
-                match self.client
+                match self
+                    .client
                     .get_rel_size(page_api::GetRelSizeRequest {
                         read_lsn,
                         rel,