From 7703bfae83db557eeffb621066ba80eac5e98238 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Karolis=20Gudi=C5=A1kis?= <karolisgud@gmail.com>
Date: Wed, 6 Mar 2024 10:47:26 +0200
Subject: [PATCH] Fix info

---
 dozer-ingestion/aerospike/src/connector.rs | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/dozer-ingestion/aerospike/src/connector.rs b/dozer-ingestion/aerospike/src/connector.rs
index e4ed242caa..a860dfe894 100644
--- a/dozer-ingestion/aerospike/src/connector.rs
+++ b/dozer-ingestion/aerospike/src/connector.rs
@@ -379,12 +379,15 @@ async fn batch_event_request_handler(
 
     let mut mapped_messages = vec![];
     trace!("Aerospike events {:?}", events);
+    info!("Events counts: {}", events.len());
     for event in events {
         mapped_messages.push(map_events(event, &state.tables_index_map).await);
     }
 
+    info!("Mapped events count {}", mapped_messages.len());
     let last_idx = mapped_messages.len() - 1;
     for (idx, mapped_message) in mapped_messages.into_iter().enumerate() {
+        info!("Left in batch {}", last_idx - idx);
         match mapped_message {
             Ok(Some(message)) => {
                 trace!("Mapped message {:?}", message);