build(repo): Comment out set panic hook on Publisher

FuelLabs · Oct 28, 2024 · bdca120 · bdca120
1 parent 32534f1
commit bdca120
Showing 1 changed file with 20 additions and 20 deletions.
diff --git a/crates/fuel-streams-publisher/src/publisher.rs b/crates/fuel-streams-publisher/src/publisher.rs
@@ -190,25 +190,25 @@ impl Publisher {
         &self.streams
     }
 
-    fn set_panic_hook(&mut self) {
-        let nats_client = self.nats_client.clone();
-        let fuel_service = Arc::clone(&self.fuel_service);
-        std::panic::set_hook(Box::new(move |panic_info| {
-            let payload = panic_info
-                .payload()
-                .downcast_ref::<&str>()
-                .unwrap_or(&"Unknown panic");
-            tracing::error!("Publisher panicked with a message: {:?}", payload);
-            let handle = tokio::runtime::Handle::current();
-            let nats_client = nats_client.clone();
-            let fuel_service = Arc::clone(&fuel_service);
-            handle.spawn(async move {
-                Publisher::flush_await_all_streams(&nats_client).await;
-                Publisher::stop_fuel_service(&fuel_service).await;
-                std::process::exit(1);
-            });
-        }));
-    }
+    // fn set_panic_hook(&mut self) {
+    //     let nats_client = self.nats_client.clone();
+    //     let fuel_service = Arc::clone(&self.fuel_service);
+    //     std::panic::set_hook(Box::new(move |panic_info| {
+    //         let payload = panic_info
+    //             .payload()
+    //             .downcast_ref::<&str>()
+    //             .unwrap_or(&"Unknown panic");
+    //         tracing::error!("Publisher panicked with a message: {:?}", payload);
+    //         let handle = tokio::runtime::Handle::current();
+    //         let nats_client = nats_client.clone();
+    //         let fuel_service = Arc::clone(&fuel_service);
+    //         handle.spawn(async move {
+    //             Publisher::flush_await_all_streams(&nats_client).await;
+    //             Publisher::stop_fuel_service(&fuel_service).await;
+    //             std::process::exit(1);
+    //         });
+    //     }));
+    // }
 
     async fn publish_block_data(
         &self,
@@ -278,7 +278,7 @@ impl Publisher {
 
         let mut stop_handle = StopHandle::new();
         stop_handle.spawn_signal_listener();
-        self.set_panic_hook();
+        // self.set_panic_hook();
 
         let last_published_block = self
             .streams