diff --git a/aptos-indexer-processors-sdk/testing-framework/src/sdk_test_context.rs b/aptos-indexer-processors-sdk/testing-framework/src/sdk_test_context.rs
index f494bb4..204ca11 100644
--- a/aptos-indexer-processors-sdk/testing-framework/src/sdk_test_context.rs
+++ b/aptos-indexer-processors-sdk/testing-framework/src/sdk_test_context.rs
@@ -160,10 +160,7 @@ impl SdkTestContext {
         port
     }
 
-    pub fn create_transaction_stream_config(
-        &self,
-        txn_count: u64,
-    ) -> TransactionStreamConfig {
+    pub fn create_transaction_stream_config(&self, txn_count: u64) -> TransactionStreamConfig {
         let data_service_address = format!(
             "http://localhost:{}",
             self.port.as_ref().expect("Port is not set")
@@ -226,9 +223,12 @@ pub fn generate_output_file(
     let file_path = match custom_file_name {
         Some(custom_name) => {
             // If custom_file_name is present, build the file path using it
-            PathBuf::from(&output_dir).join(processor_name).join(
-                format!("{}.json", custom_name), // Including table_name in the format
-            )
+            PathBuf::from(&output_dir)
+                .join(processor_name)
+                .join(custom_name)
+                .join(
+                    format!("{}.json", table_name), // Including table_name in the format // Including table_name in the format
+                )
         },
         None => {
             // Default case: use table_name and txn_version to construct file name