diff --git a/rust/integration-tests/src/sdk_tests/default_processor_tests.rs b/rust/integration-tests/src/sdk_tests/default_processor_tests.rs
index 33f707c04..358c8b42a 100644
--- a/rust/integration-tests/src/sdk_tests/default_processor_tests.rs
+++ b/rust/integration-tests/src/sdk_tests/default_processor_tests.rs
@@ -47,8 +47,8 @@ mod tests {
         diff_test_helper::default_processor::load_data,
         sdk_tests::{
             default_processor_tests::setup_default_processor_config,
-            get_all_version_from_test_context, get_transaction_version_from_test_context,
-            run_processor_test, setup_test_environment, validate_json, DEFAULT_OUTPUT_FOLDER,
+            get_all_version_from_test_context, run_processor_test, setup_test_environment,
+            validate_json, DEFAULT_OUTPUT_FOLDER,
         },
     };
     use aptos_indexer_test_transactions::{
@@ -97,13 +97,9 @@ mod tests {
         let starting_version = *txn_versions.first().unwrap();
 
         let db_url = db.get_db_url();
-        let (indexer_processor_config, processor_name) = setup_default_processor_config(
-            &test_context,
-            starting_version as u64,
-            txn_versions.len(),
-            &db_url,
-        )
-        .await;
+        let (indexer_processor_config, processor_name) =
+            setup_default_processor_config(&test_context, starting_version as u64, 1, &db_url)
+                .await;
 
         let default_processor = DefaultProcessor::new(indexer_processor_config)
             .await
diff --git a/rust/integration-tests/src/sdk_tests/events_processor_tests.rs b/rust/integration-tests/src/sdk_tests/events_processor_tests.rs
index 0f011b856..2f98c4343 100644
--- a/rust/integration-tests/src/sdk_tests/events_processor_tests.rs
+++ b/rust/integration-tests/src/sdk_tests/events_processor_tests.rs
@@ -201,13 +201,8 @@ mod tests {
         let starting_version = *txn_versions.first().unwrap();
 
         let db_url = db.get_db_url();
-        let (indexer_processor_config, processor_name) = setup_events_processor_config(
-            &test_context,
-            starting_version as u64,
-            txn_versions.len(),
-            &db_url,
-        )
-        .await;
+        let (indexer_processor_config, processor_name) =
+            setup_events_processor_config(&test_context, starting_version as u64, 1, &db_url).await;
 
         let events_processor = EventsProcessor::new(indexer_processor_config)
             .await
diff --git a/rust/integration-tests/src/sdk_tests/token_v2_processor_tests.rs b/rust/integration-tests/src/sdk_tests/token_v2_processor_tests.rs
index bf989efeb..bdcb876d0 100644
--- a/rust/integration-tests/src/sdk_tests/token_v2_processor_tests.rs
+++ b/rust/integration-tests/src/sdk_tests/token_v2_processor_tests.rs
@@ -56,8 +56,8 @@ mod sdk_token_v2_processor_tests {
     use crate::{
         diff_test_helper::token_v2_processor::load_data,
         sdk_tests::{
-            get_all_version_from_test_context, get_transaction_version_from_test_context,
-            run_processor_test, setup_test_environment, validate_json, DEFAULT_OUTPUT_FOLDER,
+            get_all_version_from_test_context, run_processor_test, setup_test_environment,
+            validate_json, DEFAULT_OUTPUT_FOLDER,
         },
     };
     use aptos_indexer_test_transactions::{
@@ -342,14 +342,9 @@ mod sdk_token_v2_processor_tests {
         let (db, mut test_context) = setup_test_environment(&[txn]).await;
         let txn_versions = get_all_version_from_test_context(&test_context);
         let starting_version = *txn_versions.first().unwrap();
-
         let db_url = db.get_db_url();
-        let (indexer_processor_config, processor_name) = setup_token_v2_processor_config(
-            &test_context,
-            starting_version as u64,
-            txn_versions.len(),
-            &db_url,
-        );
+        let (indexer_processor_config, processor_name) =
+            setup_token_v2_processor_config(&test_context, starting_version as u64, 1, &db_url);
 
         let token_v2_processor = TokenV2Processor::new(indexer_processor_config)
             .await