remove unwrap

crates/katana/pipeline/src/stage/sequencing.rs

@@ -12,7 +12,7 @@ use katana_pool::{TransactionPool, TxPool};
 use katana_tasks::{TaskHandle, TaskSpawner};
 use tracing::error;
 
-pub type SequencingFut = BoxFuture<'static, ()>;
+pub type SequencingFut = BoxFuture<'static, Result<()>>;
 
 /// The sequencing stage is responsible for advancing the chain state.
 #[allow(missing_debug_implementations)]
@@ -62,13 +62,13 @@ impl<EF: ExecutorFactory> Sequencing<EF> {
 }
 
 impl<EF: ExecutorFactory> IntoFuture for Sequencing<EF> {
-    type Output = ();
+    type Output = Result<()>;
     type IntoFuture = SequencingFut;
 
     fn into_future(self) -> Self::IntoFuture {
         Box::pin(async move {
             // Build the messaging and block production tasks.
-            let messaging = self.run_messaging().await.unwrap();
+            let messaging = self.run_messaging().await?;
             let block_production = self.run_block_production();
 
             // Neither of these tasks should complete as they are meant to be run forever,
@@ -83,6 +83,8 @@ impl<EF: ExecutorFactory> IntoFuture for Sequencing<EF> {
                     error!(target: "sequencing", reason = ?res, "Block production task finished unexpectedly.");
                 }
             }
+
+            Ok(())
         })
     }
 }