From db5e5dd37a383bce45d4e8d35a476de0ca28bde4 Mon Sep 17 00:00:00 2001
From: kashepavadan <dkashepava@gmail.com>
Date: Fri, 15 May 2026 16:39:27 -0400
Subject: [PATCH] fixed sequencer

---
 sequencer/src/sequencer.rs | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/sequencer/src/sequencer.rs b/sequencer/src/sequencer.rs
index 5fb49fc..5341488 100644
--- a/sequencer/src/sequencer.rs
+++ b/sequencer/src/sequencer.rs
@@ -119,10 +119,10 @@ impl Sequencer {
 
         let mut batch_handle = handle.clone();
         tokio::spawn(async move {
-            batch_handle.wait_ready().await;
             let mut interval = tokio::time::interval(Duration::from_millis(100));
             loop {
                 interval.tick().await;
+                batch_handle.wait_ready().await;
                 if let Err(e) = process_pending_batch(&queue_file, &batch_handle).await {
                     error!("Batch processing failed: {e}");
                 }
@@ -130,7 +130,7 @@ impl Sequencer {
         });
 
         loop {
-            let Some(event) = sequencer.next_event().await else { break; };
+            let Some(event) = sequencer.next_event().await else { continue; };
             handle_event(event, &handle, &mut state, &checkpoint_path).await;
         }
     }