diff --git a/cli/src/node/mod.rs b/cli/src/node/mod.rs
index 9a17fd0f5..f1645d50a 100644
--- a/cli/src/node/mod.rs
+++ b/cli/src/node/mod.rs
@@ -486,7 +486,7 @@ impl Node {
             supported_block_version: 50,
             supported_capabilities: supported_capabilities(),
             max_collate_threads: 1,
-            test_validators_keypairs: vec![]
+            test_validators_keypairs: vec![],
         };
 
         let collation_manager = CollationManager::start(
diff --git a/consensus/examples/consensus_node.rs b/consensus/examples/consensus_node.rs
index a9427eda6..de9288219 100644
--- a/consensus/examples/consensus_node.rs
+++ b/consensus/examples/consensus_node.rs
@@ -126,8 +126,7 @@ impl CmdRun {
         }
 
         let (committed_tx, committed_rx) = mpsc::unbounded_channel();
-        let engine =
-            Engine::new(key_pair.clone(), &dht_client, &overlay, committed_tx).await;
+        let engine = Engine::new(key_pair.clone(), &dht_client, &overlay, committed_tx).await;
         drain_anchors(committed_rx);
 
         tracing::info!(
@@ -186,11 +185,8 @@ impl CmdGenDht {
     fn run(self) -> Result<()> {
         let secret_key = parse_key(&self.key)?;
         let key_pair = Arc::new(KeyPair::from(&secret_key));
-        let entry = tycho_consensus::test_utils::make_peer_info(
-            key_pair,
-            self.addr.into(),
-            self.ttl,
-        );
+        let entry =
+            tycho_consensus::test_utils::make_peer_info(key_pair, self.addr.into(), self.ttl);
         let output = if std::io::stdin().is_terminal() {
             serde_json::to_string_pretty(&entry)
         } else {
diff --git a/consensus/src/test_utils.rs b/consensus/src/test_utils.rs
index b3b6bf959..7c0434b3c 100644
--- a/consensus/src/test_utils.rs
+++ b/consensus/src/test_utils.rs
@@ -165,7 +165,9 @@ mod tests {
         }
         let mut engines = vec![];
         let (committed_tx, committed_rx) = mpsc::unbounded_channel();
-        for (key_pair, (dht_client, overlay_service)) in keys.into_iter().zip(from_validators.iter()) {
+        for (key_pair, (dht_client, overlay_service)) in
+            keys.into_iter().zip(from_validators.iter())
+        {
             let engine = Engine::new(
                 key_pair.clone(),
                 &dht_client,