From d16d5f76b2834b1d1ecbe8a7c3d33fe0ce14c663 Mon Sep 17 00:00:00 2001
From: Sergio Chouhy <sergio.chouhy@gmail.com>
Date: Wed, 18 Feb 2026 12:21:58 -0300
Subject: [PATCH] small changes

---
 indexer/core/src/lib.rs                          |  4 +++-
 .../configs/debug/sequencer_config.json          |  2 +-
 sequencer_runner/src/lib.rs                      | 16 ++++++++++++----
 3 files changed, 16 insertions(+), 6 deletions(-)

diff --git a/indexer/core/src/lib.rs b/indexer/core/src/lib.rs
index 283842b8..e81faf9a 100644
--- a/indexer/core/src/lib.rs
+++ b/indexer/core/src/lib.rs
@@ -65,7 +65,9 @@ impl IndexerCore {
                             &self.config.channel_id,
                         ).collect::<Vec<_>>();
 
-                        info!("Parsed {} L2 blocks", l2_blocks_parsed.len());
+                        let mut l2_blocks_parsed_ids: Vec<_> = l2_blocks_parsed.iter().map(|block| block.header.block_id).collect();
+                        l2_blocks_parsed_ids.sort();
+                        info!("Parsed {} L2 blocks with ids {:?}", l2_blocks_parsed.len(), l2_blocks_parsed_ids);
 
                         for l2_block in l2_blocks_parsed {
                             // State modification, will be updated in future
diff --git a/sequencer_runner/configs/debug/sequencer_config.json b/sequencer_runner/configs/debug/sequencer_config.json
index aee66f42..8974790c 100644
--- a/sequencer_runner/configs/debug/sequencer_config.json
+++ b/sequencer_runner/configs/debug/sequencer_config.json
@@ -5,7 +5,7 @@
     "is_genesis_random": true,
     "max_num_tx_in_block": 20,
     "mempool_max_size": 1000,
-    "block_create_timeout_millis": 2000,
+    "block_create_timeout_millis": 15000,
     "retry_pending_blocks_timeout_millis": 500,
     "port": 3040,
     "bedrock_config": {
diff --git a/sequencer_runner/src/lib.rs b/sequencer_runner/src/lib.rs
index 74c22a6f..2ea5f422 100644
--- a/sequencer_runner/src/lib.rs
+++ b/sequencer_runner/src/lib.rs
@@ -1,4 +1,9 @@
-use std::{net::SocketAddr, path::PathBuf, sync::Arc, time::Duration};
+use std::{
+    net::SocketAddr,
+    path::PathBuf,
+    sync::Arc,
+    time::{Duration, Instant},
+};
 
 use actix_web::dev::ServerHandle;
 use anyhow::{Context as _, Result};
@@ -12,7 +17,6 @@ use sequencer_core::{
 };
 use sequencer_rpc::new_http_server;
 use tokio::{sync::Mutex, task::JoinHandle};
-use std::time::Instant;
 
 pub const RUST_LOG: &str = "RUST_LOG";
 
@@ -164,7 +168,7 @@ async fn retry_pending_blocks_loop(
     loop {
         tokio::time::sleep(retry_pending_blocks_timeout).await;
 
-        let (pending_blocks, block_settlement_client) = {
+        let (mut pending_blocks, block_settlement_client) = {
             let sequencer_core = seq_core.lock().await;
             let client = sequencer_core.block_settlement_client();
             let pending_blocks = sequencer_core
@@ -173,7 +177,11 @@ async fn retry_pending_blocks_loop(
             (pending_blocks, client)
         };
 
-        for block in &pending_blocks {
+        let k = 50;
+        if pending_blocks.len() > k {
+            pending_blocks.select_nth_unstable_by_key(k, |b| b.header.block_id);
+        }
+        for block in pending_blocks.iter().take(k) {
             info!(
                 "Resubmitting pending block with id {}",
                 block.header.block_id