From 4ca8c9f137d2328735d4094199a6d0648f9b95e2 Mon Sep 17 00:00:00 2001 From: Waqar Ahmed Khan Date: Mon, 12 Aug 2024 16:56:42 -0700 Subject: [PATCH] cargo fmt --- runners/s3-benchrunner-rust/src/transfer_manager.rs | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/runners/s3-benchrunner-rust/src/transfer_manager.rs b/runners/s3-benchrunner-rust/src/transfer_manager.rs index 9c9071b3..882ab606 100644 --- a/runners/s3-benchrunner-rust/src/transfer_manager.rs +++ b/runners/s3-benchrunner-rust/src/transfer_manager.rs @@ -13,11 +13,9 @@ use tokio::task::JoinSet; use crate::{ BenchmarkConfig, Result, RunBenchmark, RunnerError, TaskAction, TaskConfig, PART_SIZE, - }; use bytes::Bytes; - /// Benchmark runner using aws-s3-transfer-manager #[derive(Clone)] pub struct TransferManagerRunner { @@ -46,7 +44,9 @@ impl TransferManagerRunner { let upload_data_size: usize = if config.workload.files_on_disk { 0 } else { - config.workload.tasks + config + .workload + .tasks .iter() .filter(|task| task.action == TaskAction::Upload) .map(|task| task.size) @@ -56,7 +56,7 @@ impl TransferManagerRunner { .unwrap() }; let random_data_for_upload: Bytes = { - let mut data = Vec::new(); + let mut data = Vec::new(); data.resize_with(upload_data_size, rand::random::); data.into() }; @@ -145,10 +145,9 @@ impl TransferManagerRunner { let stream = match self.config().workload.files_on_disk { true => InputStream::from_path(key).with_context(|| "Failed to create stream")?, - false => self.handle.random_data_for_upload.clone().into(), + false => self.handle.random_data_for_upload.clone().into(), }; - self.handle .transfer_manager .upload()