Format

Author: grahamc

magic-nix-cache/src/binary_cache.rs

@@ -96,10 +96,8 @@ async fn put_narinfo(
     let allocation = gha_cache.api.allocate_file_with_random_suffix(&key).await?;
 
     let body_stream = body.into_data_stream();
-    let stream = StreamReader::new(
-        body_stream
-            .map(|r| r.map_err(|e| std::io::Error::other(e.to_string()))),
-    );
+    let stream =
+        StreamReader::new(body_stream.map(|r| r.map_err(|e| std::io::Error::other(e.to_string()))));
 
     gha_cache.api.upload_file(allocation, stream).await?;
     state.metrics.narinfos_uploaded.incr();
@@ -147,10 +145,8 @@ async fn put_nar(
         .await?;
 
     let body_stream = body.into_data_stream();
-    let stream = StreamReader::new(
-        body_stream
-            .map(|r| r.map_err(|e| std::io::Error::other(e.to_string()))),
-    );
+    let stream =
+        StreamReader::new(body_stream.map(|r| r.map_err(|e| std::io::Error::other(e.to_string()))));
 
     gha_cache.api.upload_file(allocation, stream).await?;
     state.metrics.nars_uploaded.incr();

magic-nix-cache/src/gha.rs

@@ -176,9 +176,7 @@ async fn upload_path(
 
     let nar_stream = store.nar_from_path(path.clone());
 
-    let nar_reader = nar_stream
-        .map_err(std::io::Error::other)
-        .into_async_read();
+    let nar_reader = nar_stream.map_err(std::io::Error::other).into_async_read();
 
     let nar_compressor = ZstdEncoder::new(nar_reader.compat());
 

magic-nix-cache/src/main.rs

@@ -296,10 +296,7 @@ async fn main_cli(args: Args, recorder: detsys_ids_client::Recorder) -> Result<(
         )
         .await;
     recorder
-        .set_fact(
-            "dnixd_availability",
-            format!("{dnixd_available:?}").into(),
-        )
+        .set_fact("dnixd_availability", format!("{dnixd_available:?}").into())
         .await;
 
     let flakehub_auth_method: Option<FlakeHubAuthSource> = match (