3 files changed, 17 insertions, 18 deletions

diff --git a/src/address_allocation_policy.rs b/src/address_allocation_policy.rs
index 758ab21..1d282c3 100644
--- a/src/address_allocation_policy.rs
+++ b/src/address_allocation_policy.rs
@@ -153,4 +153,3 @@ mod tests {
         assert!(AddressAllocationPolicy::from_str("10/ cpu").is_err());
     }
 }
-
diff --git a/src/context.rs b/src/context.rs
index 4c1b639..1ca4f68 100644
--- a/src/context.rs
+++ b/src/context.rs
@@ -15,7 +15,7 @@ pub struct Context {
     job_id: Option<u32>,
     infer_job_id: bool,
     frontend_hostname: Option<String>,
-    cluster_username: Option<String>
+    cluster_username: Option<String>,
 }
 
 impl Context {
@@ -23,14 +23,14 @@ impl Context {
         job_id: Option<u32>,
         infer_job_id: bool,
         frontend_hostname: Option<String>,
-        cluster_username: Option<String>
+        cluster_username: Option<String>,
     ) -> Result<Self> {
         Ok(Self {
             node: get_execution_node().await?,
             job_id,
             infer_job_id,
             frontend_hostname,
-            cluster_username
+            cluster_username,
         })
     }
 
diff --git a/src/main.rs b/src/main.rs
index 64b2b1f..ec3f8f1 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -61,7 +61,6 @@ struct Common {
     /// cluster username, needed if running locally with differing usernames
     #[clap(long, env = "CLUSTER_USERNAME")]
     cluster_username: Option<String>,
-
 }
 
 #[derive(Debug, Subcommand)]
@@ -245,7 +244,7 @@ async fn context_from_common(common: &Common) -> Result<Context> {
         common.job_id,
         common.infer_job_id,
         common.frontend_hostname.clone(),
-        common.cluster_username.clone()
+        common.cluster_username.clone(),
     )
     .await?;
 
@@ -692,7 +691,9 @@ async fn machine_containers_save_logs(
 async fn machine_copy_logs_dir(ctx: &Context, machine: Machine, output_dir: &Path) -> Result<()> {
     tracing::info!("copying container logs from machine");
 
-    let mut rsync_rsh = "ssh -o ConnectionAttempts=3 -o StrictHostKeyChecking=no -o UserKnownHostsFile=/dev/null".to_string();
+    let mut rsync_rsh =
+        "ssh -o ConnectionAttempts=3 -o StrictHostKeyChecking=no -o UserKnownHostsFile=/dev/null"
+            .to_string();
     if ctx.node == ExecutionNode::Unknown {
         rsync_rsh += &format!(" -J {}", ctx.frontend_hostname()?);
     }
@@ -828,9 +829,9 @@ async fn machine_run(
             arguments.push("-J");
             arguments.push(frontend);
             if ctx.cluster_username().is_ok() {
-                    arguments.push("-l");
-                    arguments.push(ctx.cluster_username()?);
-                }
+                arguments.push("-l");
+                arguments.push(ctx.cluster_username()?);
+            }
             arguments.push(machine.hostname());
             arguments
         }
@@ -1072,14 +1073,13 @@ fn machine_generate_configs(
             .push(address);
     }
 
-    if !matrix_wrap
-        && addresses.len() > matrix.dimension() {
-            return Err(eyre::eyre!(
-                "latency matrix is too small, size is {} but {} was required",
-                matrix.dimension(),
-                addresses.len()
-            ));
-        }
+    if !matrix_wrap && addresses.len() > matrix.dimension() {
+        return Err(eyre::eyre!(
+            "latency matrix is too small, size is {} but {} was required",
+            matrix.dimension(),
+            addresses.len()
+        ));
+    }
 
     for &machine in machines {
         let machine_addresses = &addresses_per_machine[&machine];