From 730b5f280facebc9ae9492eb76f8e4be354b2aa1 Mon Sep 17 00:00:00 2001
From: Neal Fachan <neal@fachan.com>
Date: Tue, 15 Oct 2024 10:48:31 -0700
Subject: [PATCH] Run rustfmt.

---
 .../src/scheduler_task/scheduler.rs           | 25 ++++++++-----------
 1 file changed, 10 insertions(+), 15 deletions(-)

diff --git a/crates/maelstrom-broker/src/scheduler_task/scheduler.rs b/crates/maelstrom-broker/src/scheduler_task/scheduler.rs
index 6dbd8f54..6d99b233 100644
--- a/crates/maelstrom-broker/src/scheduler_task/scheduler.rs
+++ b/crates/maelstrom-broker/src/scheduler_task/scheduler.rs
@@ -861,8 +861,7 @@ mod tests {
         get_artifact_returns: HashMap<(JobId, Sha256Digest), Vec<GetArtifact>>,
         got_artifact_returns: HashMap<Sha256Digest, Vec<Vec<JobId>>>,
         #[allow(clippy::type_complexity)]
-        get_artifact_for_worker_returns:
-            HashMap<Sha256Digest, Vec<Option<(PathBuf, u64)>>>,
+        get_artifact_for_worker_returns: HashMap<Sha256Digest, Vec<Option<(PathBuf, u64)>>>,
         read_manifest_returns: HashMap<Sha256Digest, Vec<ManifestEntry>>,
     }
 
@@ -881,10 +880,9 @@ mod tests {
         }
 
         fn got_artifact(&mut self, digest: Sha256Digest, file: Self::TempFile) -> Vec<JobId> {
-            self.borrow_mut().messages.push(CacheGotArtifact(
-                digest.clone(),
-                file,
-            ));
+            self.borrow_mut()
+                .messages
+                .push(CacheGotArtifact(digest.clone(), file));
             self.borrow_mut()
                 .got_artifact_returns
                 .get_mut(&digest)
@@ -904,10 +902,7 @@ mod tests {
                 .push(CacheClientDisconnected(cid));
         }
 
-        fn get_artifact_for_worker(
-            &mut self,
-            digest: &Sha256Digest,
-        ) -> Option<(PathBuf, u64)> {
+        fn get_artifact_for_worker(&mut self, digest: &Sha256Digest) -> Option<(PathBuf, u64)> {
             self.borrow_mut()
                 .messages
                 .push(CacheGetArtifactForWorker(digest.clone()));
@@ -1007,10 +1002,7 @@ mod tests {
         fn new<const L: usize, const M: usize, const N: usize, const O: usize>(
             get_artifact_returns: [((JobId, Sha256Digest), Vec<GetArtifact>); L],
             got_artifact_returns: [(Sha256Digest, Vec<Vec<JobId>>); M],
-            get_artifact_for_worker_returns: [(
-                Sha256Digest,
-                Vec<Option<(PathBuf, u64)>>,
-            ); N],
+            get_artifact_for_worker_returns: [(Sha256Digest, Vec<Option<(PathBuf, u64)>>); N],
             read_manifest_returns: [(Sha256Digest, Vec<ManifestEntry>); O],
         ) -> Self {
             let result = Self::default();
@@ -1044,7 +1036,10 @@ mod tests {
             );
         }
 
-        fn receive_message(&mut self, msg: Message<Rc<RefCell<TestState>>, cache::fs::test::TempFile>) {
+        fn receive_message(
+            &mut self,
+            msg: Message<Rc<RefCell<TestState>>, cache::fs::test::TempFile>,
+        ) {
             self.scheduler.receive_message(&mut self.test_state, msg);
         }
     }