fix(derive): formatting

Author: refcell

crates/derive/src/stages/channel_bank.rs

@@ -126,10 +126,8 @@ where
     pub fn read(&mut self) -> StageResult<Option<Bytes>> {
         // Bail if there are no channels to read from.
         if self.channel_queue.is_empty() {
-            self.telemetry.write(
-                alloy_primitives::Bytes::from("No channels to read from"),
-                LogLevel::Debug,
-            );
+            self.telemetry
+                .write(alloy_primitives::Bytes::from("No channels to read from"), LogLevel::Debug);
             return Err(StageError::Eof);
         }
 

crates/derive/src/stages/channel_reader.rs

@@ -40,10 +40,8 @@ where
     /// Pulls out the next Batch from the available channel.
     pub async fn next_batch(&mut self) -> StageResult<Batch> {
         if let Err(e) = self.set_batch_reader().await {
-            self.telemetry.write(
-                alloc::format!("Failed to set batch reader: {:?}", e),
-                LogLevel::Error,
-            );
+            self.telemetry
+                .write(alloc::format!("Failed to set batch reader: {:?}", e), LogLevel::Error);
             self.next_channel();
             return Err(e);
         }

crates/derive/src/stages/frame_queue.rs

@@ -92,7 +92,8 @@ where
 pub(crate) mod tests {
     use super::*;
     use crate::{
-        stages::l1_traversal::tests::new_test_traversal, traits::test_utils::{TestDAP, TestTelemetry},
+        stages::l1_traversal::tests::new_test_traversal,
+        traits::test_utils::{TestDAP, TestTelemetry},
         DERIVATION_VERSION_0,
     };
     use alloc::{vec, vec::Vec};

crates/derive/src/stages/l1_retrieval.rs

@@ -37,7 +37,8 @@ where
     CP: ChainProvider,
     T: TelemetryProvider,
 {
-    /// Creates a new L1 retrieval stage with the given data availability provider and previous stage.
+    /// Creates a new L1 retrieval stage with the given data availability provider and previous
+    /// stage.
     pub fn new(prev: L1Traversal<CP, T>, provider: DAP, telemetry: T) -> Self {
         Self { prev, telemetry, provider, data: None }
     }
@@ -142,7 +143,8 @@ mod tests {
         let traversal = new_test_traversal(false, false);
         let telemetry = TestTelemetry::new();
         let dap = TestDAP { results: vec![] };
-        let mut retrieval = L1Retrieval { prev: traversal, telemetry, provider: dap, data: Some(data) };
+        let mut retrieval =
+            L1Retrieval { prev: traversal, telemetry, provider: dap, data: Some(data) };
         let data = retrieval.next_data().await.unwrap();
         assert_eq!(data, Bytes::default());
         assert!(retrieval.data.is_some());
@@ -159,7 +161,8 @@ mod tests {
         let telemetry = TestTelemetry::new();
         let traversal = new_test_traversal(true, true);
         let dap = TestDAP { results: vec![] };
-        let mut retrieval = L1Retrieval { prev: traversal, telemetry, provider: dap, data: Some(data) };
+        let mut retrieval =
+            L1Retrieval { prev: traversal, telemetry, provider: dap, data: Some(data) };
         let data = retrieval.next_data().await.unwrap_err();
         assert_eq!(data, StageError::Eof);
         assert!(retrieval.data.is_none());

crates/derive/src/traits/test_utils/telemetry.rs

@@ -1,8 +1,7 @@
 //! Test Utilities for Telemetry
 
 use crate::traits::{LogLevel, TelemetryProvider};
-use alloc::rc::Rc;
-use alloc::vec::Vec;
+use alloc::{rc::Rc, vec::Vec};
 use alloy_primitives::Bytes;
 use core::cell::RefCell;