From c2d4e717e4493253a995946e10c381434187b12d Mon Sep 17 00:00:00 2001 From: Sergio Chouhy Date: Wed, 18 Feb 2026 12:21:58 -0300 Subject: [PATCH] small changes --- indexer/core/src/lib.rs | 4 +++- sequencer_runner/configs/debug/sequencer_config.json | 2 +- sequencer_runner/src/lib.rs | 8 ++++++-- 3 files changed, 10 insertions(+), 4 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::>(); - 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 358bd37f..4975ec01 100644 --- a/sequencer_runner/src/lib.rs +++ b/sequencer_runner/src/lib.rs @@ -175,7 +175,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 @@ -184,7 +184,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