fmt

apollo-router/src/compute_job.rs

@@ -128,12 +128,10 @@ mod tests {
     #[tokio::test]
     async fn test_executes_on_different_thread() {
         let test_thread = std::thread::current().id();
-        let job_thread = execute(Priority::P4, || {
-            std::thread::current().id()
-        })
-        .unwrap()
-        .await
-        .unwrap();
+        let job_thread = execute(Priority::P4, || std::thread::current().id())
+            .unwrap()
+            .await
+            .unwrap();
         assert_ne!(job_thread, test_thread)
     }
 

apollo-router/src/introspection.rs

@@ -160,10 +160,9 @@ impl IntrospectionCache {
         let schema = schema.clone();
         let doc = doc.clone();
         let priority = compute_job::Priority::P1; // Low priority
-        let response = compute_job::execute(
-            priority,
-            move || Self::execute_introspection(max_depth, &schema, &doc),
-        )?
+        let response = compute_job::execute(priority, move || {
+            Self::execute_introspection(max_depth, &schema, &doc)
+        })?
         // `expect()` propagates any panic that potentially happens in the closure, but:
         //
         // * We try to avoid such panics in the first place and consider them bugs

apollo-router/src/services/supergraph/service.rs

@@ -219,8 +219,9 @@ async fn service_call(
         Err(err) => {
             let status = match &err {
                 CacheResolverError::Backpressure(_) => StatusCode::SERVICE_UNAVAILABLE,
-                CacheResolverError::RetrievalError(_) |
-                CacheResolverError::BatchingError(_) => StatusCode::BAD_REQUEST,
+                CacheResolverError::RetrievalError(_) | CacheResolverError::BatchingError(_) => {
+                    StatusCode::BAD_REQUEST
+                }
             };
             match err.into_graphql_errors() {
                 Ok(gql_errors) => {