rebase

core/src/event/callback_registry.rs

@@ -148,7 +148,7 @@ impl EventCallbackRegistry {
                     info!("Detected shutdown, stopping event trigger");
                     break;
                 }
-                
+
                 match (event_information.callback)(data.clone()).await {
                     Ok(_) => {
                         debug!(

core/src/indexer/process.rs

@@ -99,7 +99,7 @@ pub async fn process_contracts_events_with_dependencies(
                 contract_events.event_dependencies,
                 Arc::new(contract_events.events_config),
             )
-                .await
+            .await
         });
         handles.push(handle);
     }

core/src/system_state.rs

@@ -6,9 +6,7 @@ use std::{
 use once_cell::sync::Lazy;
 use tracing::info;
 
-use crate::{
-    indexer::task_tracker::active_indexing_count,
-};
+use crate::indexer::task_tracker::active_indexing_count;
 
 static IS_RUNNING: Lazy<AtomicBool> = Lazy::new(|| AtomicBool::new(true));