diff --git a/crates/tracedecay-sessions/src/runtime/hosts/pi.rs b/crates/tracedecay-sessions/src/runtime/hosts/pi.rs
index ebee062b68..8e50ad9f86 100644
--- a/crates/tracedecay-sessions/src/runtime/hosts/pi.rs
+++ b/crates/tracedecay-sessions/src/runtime/hosts/pi.rs
@@ -104,7 +104,10 @@ fn file_stamp(metadata: &std::fs::Metadata) -> PathFileStamp {
     let (mtime_secs, inode) = {
         use std::os::unix::fs::MetadataExt;
         (
-            metadata.mtime().unsigned_abs().saturating_mul(1_000_000_000)
+            metadata
+                .mtime()
+                .unsigned_abs()
+                .saturating_mul(1_000_000_000)
                 + metadata.mtime_nsec().unsigned_abs(),
             metadata.ino(),
         )
@@ -923,8 +926,12 @@ async fn admit_scheduled_file(
     // re-enter admission, or every restart re-pays the whole corpus.
     let stamp = {
         let path_buf = path.to_path_buf();
-        run_blocking_transcript_section("pi", move || std::fs::metadata(&path_buf).ok().map(|meta| file_stamp(&meta)))
-            .await?
+        run_blocking_transcript_section("pi", move || {
+            std::fs::metadata(&path_buf)
+                .ok()
+                .map(|meta| file_stamp(&meta))
+        })
+        .await?
     };
     if let Some(stamp) = stamp {
         if path_memo_matches(facade, scope, PI_COMPLETE_MEMO_PREFIX, path, stamp).await {
diff --git a/crates/tracedecay/src/daemon/hook_v2_replay_consumer.rs b/crates/tracedecay/src/daemon/hook_v2_replay_consumer.rs
index e5dd4ba6bf..c4456b06fd 100644
--- a/crates/tracedecay/src/daemon/hook_v2_replay_consumer.rs
+++ b/crates/tracedecay/src/daemon/hook_v2_replay_consumer.rs
@@ -95,9 +95,8 @@ struct PendingWorkRedriveState {
     terminal: bool,
 }
 
-static PENDING_WORK_REDRIVE_GATE: std::sync::OnceLock<
-    std::sync::Mutex<PendingWorkRedriveGate>,
-> = std::sync::OnceLock::new();
+static PENDING_WORK_REDRIVE_GATE: std::sync::OnceLock<std::sync::Mutex<PendingWorkRedriveGate>> =
+    std::sync::OnceLock::new();
 
 fn pending_work_redrive_gate() -> &'static std::sync::Mutex<PendingWorkRedriveGate> {
     PENDING_WORK_REDRIVE_GATE
@@ -393,8 +392,9 @@ async fn redrive_pending_work(
                     );
                 }
             } else {
-                state.next_eligible_micros =
-                    now.0.saturating_add(pending_work_redrive_backoff(state.attempts));
+                state.next_eligible_micros = now
+                    .0
+                    .saturating_add(pending_work_redrive_backoff(state.attempts));
             }
         } else {
             let mut gate = pending_work_redrive_gate()