Skip to content

Commit

Permalink
update generate_outpu_file function to correctly strcuture output folder
Browse files Browse the repository at this point in the history
  • Loading branch information
yuunlimm committed Oct 21, 2024
1 parent bd7b619 commit 97abd53
Showing 1 changed file with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down Expand Up @@ -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),
)
},
None => {
// Default case: use table_name and txn_version to construct file name
Expand Down

0 comments on commit 97abd53

Please sign in to comment.