diff --git a/atoma-bin/atoma_node.rs b/atoma-bin/atoma_node.rs index 721e950a..4340b395 100644 --- a/atoma-bin/atoma_node.rs +++ b/atoma-bin/atoma_node.rs @@ -1,5 +1,7 @@ use std::{ -path::{Path, PathBuf}, str::FromStr, sync::Arc + path::{Path, PathBuf}, + str::FromStr, + sync::Arc, }; use anyhow::{Context, Result}; @@ -215,15 +217,20 @@ async fn main() -> Result<()> { async move { let p2p_node = AtomaP2pNode::start(config.p2p, Arc::new(keystore), p2p_event_sender, false)?; - let _ = Box::pin(p2p_node.run(p2p_node_service_shutdown_receiver).await.map_err(|e| { - error!( - target = "atoma-node-service", - event = "p2p_node_service_shutdown", - error = %e, - "P2P node service shutdown" - ); - anyhow::anyhow!(e) - })); + let _ = Box::pin( + p2p_node + .run(p2p_node_service_shutdown_receiver) + .await + .map_err(|e| { + error!( + target = "atoma-node-service", + event = "p2p_node_service_shutdown", + error = %e, + "P2P node service shutdown" + ); + anyhow::anyhow!(e) + }), + ); Ok::<(), anyhow::Error>(()) }, shutdown_sender.clone(),