diff --git a/indexer/core/src/lib.rs b/indexer/core/src/lib.rs index 8d34ede0..0959249b 100644 --- a/indexer/core/src/lib.rs +++ b/indexer/core/src/lib.rs @@ -139,6 +139,9 @@ impl IndexerCore { info!("Searching for initial header finished"); + info!("Moving one block into future in case if channel start was on first L1 block"); + prev_last_l1_lib_header = self.get_next_lib(prev_last_l1_lib_header).await?; + info!("Starting backfilling from {prev_last_l1_lib_header}"); loop { diff --git a/indexer/service/configs/indexer_config.json b/indexer/service/configs/indexer_config.json index 7d7a317c..247caa8e 100644 --- a/indexer/service/configs/indexer_config.json +++ b/indexer/service/configs/indexer_config.json @@ -1,6 +1,6 @@ { "home": "./indexer/service", - "consensus_info_polling_interval": "1s", + "consensus_info_polling_interval": "60s", "bedrock_client_config": { "addr": "http://localhost:8080", "backoff": { diff --git a/sequencer_runner/src/lib.rs b/sequencer_runner/src/lib.rs index 8bef705e..d74792c8 100644 --- a/sequencer_runner/src/lib.rs +++ b/sequencer_runner/src/lib.rs @@ -182,6 +182,14 @@ async fn retry_pending_blocks(seq_core: &Arc>) -> Result<() (pending_blocks, client) }; + if !pending_blocks.is_empty() { + info!( + "Resubmitting blocks from {} to {}", + pending_blocks.first().unwrap().header.block_id, + pending_blocks.last().unwrap().header.block_id + ); + } + for block in pending_blocks.iter() { debug!( "Resubmitting pending block with id {}",