break loop if dispatch fail

lambdaclass · Nov 15, 2024 · c5bae2d · c5bae2d
1 parent b11df04
commit c5bae2d
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/core/node/da_dispatcher/src/da_dispatcher.rs b/core/node/da_dispatcher/src/da_dispatcher.rs
@@ -79,6 +79,10 @@ impl DataAvailabilityDispatcher {
                 tracing::info!("Stop signal received, da_dispatcher is shutting down");
                 break;
             }
+            if *shutdown_rx.borrow() {
+                tracing::error!("A blob dispatch failed, da_dispatcher is shutting down");
+                break;
+            }
 
             let mut conn = self.pool.connection_tagged("da_dispatcher").await?;
             let batches = conn