diff --git a/committer/src/main.rs b/committer/src/main.rs index 7fc9cf1b..9ad0ebfe 100644 --- a/committer/src/main.rs +++ b/committer/src/main.rs @@ -72,6 +72,7 @@ async fn main() -> Result<()> { &config, &internal_config, &metrics_registry, + finalization_metric.clone(), )? } else if config.da_layer.is_some() { setup::eigen_da_services( @@ -81,6 +82,7 @@ async fn main() -> Result<()> { &config, &internal_config, &metrics_registry, + finalization_metric, ) .await? } else { diff --git a/committer/src/setup.rs b/committer/src/setup.rs index 698c020b..169154fe 100644 --- a/committer/src/setup.rs +++ b/committer/src/setup.rs @@ -78,6 +78,7 @@ pub fn block_committer( ) } +#[allow(clippy::too_many_arguments)] pub fn ethereum_da_services( fuel: FuelApi, ethereum_rpc: L1, @@ -86,6 +87,7 @@ pub fn ethereum_da_services( config: &config::Config, internal_config: &config::Internal, registry: &Registry, + last_finalization: IntGauge, ) -> Result>> { let block_bundler = block_bundler( fuel.clone(), @@ -119,7 +121,7 @@ pub fn ethereum_da_services( cancel_token.clone(), registry, config, - last_finalization_metric(), + last_finalization.clone(), ); let state_importer_handle = block_importer( @@ -152,6 +154,7 @@ pub async fn eigen_da_services( config: &config::Config, internal_config: &config::Internal, registry: &Registry, + last_finalization: IntGauge, ) -> Result>> { let block_bundler = eigen_block_bundler( fuel.clone(), @@ -180,7 +183,7 @@ pub async fn eigen_da_services( cancel_token.clone(), config, registry, - last_finalization_metric(), + last_finalization.clone(), )?; let fee_metrics_handle =