diff --git a/src/fixtures.rs b/src/fixtures.rs
index 57075e9f6f..33379d82d1 100644
--- a/src/fixtures.rs
+++ b/src/fixtures.rs
@@ -130,7 +130,7 @@ pub async fn tmprepo(kind: &str) -> TempRepo {
             let repo = Arc::new(spfs::storage::RepositoryHandle::FS(
                 spfs::storage::fs::FSRepository::create(tmpdir.path().join("repo"))
                     .await
-                    .unwrap()
+                    .unwrap(),
             ));
             let listen: std::net::SocketAddr = "127.0.0.1:0".parse().unwrap();
             let http_listener = std::net::TcpListener::bind(listen).unwrap();
diff --git a/src/server/database.rs b/src/server/database.rs
index 68b6ecf66b..f48bc8db89 100644
--- a/src/server/database.rs
+++ b/src/server/database.rs
@@ -31,9 +31,7 @@ impl proto::database_service_server::DatabaseService for DatabaseService {
     ) -> Result<Response<proto::ReadObjectResponse>, Status> {
         let request = request.into_inner();
         let digest = proto::handle_error!(request.digest.try_into());
-        let object = {
-            proto::handle_error!(self.repo.read_object(digest).await)
-        };
+        let object = { proto::handle_error!(self.repo.read_object(digest).await) };
         let result = proto::ReadObjectResponse::ok((&object).into());
         Ok(Response::new(result))
     }
@@ -56,14 +54,18 @@ impl proto::database_service_server::DatabaseService for DatabaseService {
         &self,
         _request: Request<proto::IterObjectsRequest>,
     ) -> Result<Response<Self::IterObjectsStream>, Status> {
-        Err(Status::unimplemented("object iteration is no yet supported directly over gRPC"))
+        Err(Status::unimplemented(
+            "object iteration is no yet supported directly over gRPC",
+        ))
     }
 
     async fn walk_objects(
         &self,
         _request: Request<proto::WalkObjectsRequest>,
     ) -> Result<Response<Self::WalkObjectsStream>, Status> {
-        Err(Status::unimplemented("object walking is no yet supported directly over gRPC"))
+        Err(Status::unimplemented(
+            "object walking is no yet supported directly over gRPC",
+        ))
     }
 
     async fn write_object(
diff --git a/src/server/tag.rs b/src/server/tag.rs
index 6847f44223..ea989c3262 100644
--- a/src/server/tag.rs
+++ b/src/server/tag.rs
@@ -25,9 +25,7 @@ impl proto::tag_service_server::TagService for TagService {
         tracing::trace!("recieve request");
         let request = request.into_inner();
         let path = relative_path::RelativePath::new(&request.path);
-        let entries: crate::Result<Vec<_>> = {
-            self.repo.ls_tags(path).collect().await
-        };
+        let entries: crate::Result<Vec<_>> = { self.repo.ls_tags(path).collect().await };
         let entries = proto::handle_error!(entries);
 
         let data = proto::LsTagsResponse::ok(proto::ls_tags_response::EntryList { entries });
diff --git a/src/storage/database_test.rs b/src/storage/database_test.rs
index a7dc934c85..db1679a7f4 100644
--- a/src/storage/database_test.rs
+++ b/src/storage/database_test.rs
@@ -19,7 +19,8 @@ async fn test_object_existance(#[future] tmprepo: TempRepo) {
     let digest = encoding::EMPTY_DIGEST.into();
     let obj = graph::Blob::new(digest, 0).into();
     tmprepo
-        .write_object(&obj).await
+        .write_object(&obj)
+        .await
         .expect("failed to write object data");
 
     let actual = tmprepo.has_object(digest).await;