diff --git a/yama/src/pile/integrity.rs b/yama/src/pile/integrity.rs
index 4d2cbcd..b741736 100644
--- a/yama/src/pile/integrity.rs
+++ b/yama/src/pile/integrity.rs
@@ -122,7 +122,9 @@ impl<RP: RawPile> RawPile for RawPileIntegrityChecker<RP> {
     ) -> anyhow::Result<Sender<(ChunkId, Vec<u8>)>> {
         // TODO primitive implementation but good enough for now.
         // May want metrics later?
-        let next_stage = self.underlying.build_storage_pipeline(settings, controller_send)?;
+        let next_stage = self
+            .underlying
+            .build_storage_pipeline(settings, controller_send)?;
         let (input, receiver) = crossbeam_channel::bounded::<(ChunkId, Vec<u8>)>(64);
         std::thread::spawn(move || {
             while let Ok((chunk_id, mut chunk)) = receiver.recv() {