Remove unneeded async qualifiers

Author: shepmaster

compiler/base/orchestrator/src/coordinator.rs

@@ -844,7 +844,7 @@ impl<B> Coordinator<B>
 where
     B: Backend,
 {
-    pub async fn new(backend: B) -> Self {
+    pub fn new(backend: B) -> Self {
         let token = CancellationToken::new();
 
         Self {
@@ -1090,8 +1090,8 @@ where
 }
 
 impl Coordinator<DockerBackend> {
-    pub async fn new_docker() -> Self {
-        Self::new(DockerBackend(())).await
+    pub fn new_docker() -> Self {
+        Self::new(DockerBackend(()))
     }
 }
 
@@ -2789,17 +2789,16 @@ mod tests {
     where
         T: Backend,
     {
-        async fn with<F, Fut>(f: F) -> Self
+        async fn with<F>(f: F) -> Self
         where
-            F: FnOnce() -> Fut,
-            Fut: Future<Output = Coordinator<T>>,
+            F: FnOnce() -> Coordinator<T>,
         {
             let semaphore = CONCURRENT_TEST_SEMAPHORE.clone();
             let permit = semaphore
                 .acquire_owned()
                 .await
                 .expect("Unable to acquire permit");
-            let coordinator = f().await;
+            let coordinator = f();
             Self {
                 _permit: permit,
                 coordinator,

ui/src/server_axum.rs

@@ -407,7 +407,7 @@ where
     for<'f> F:
         FnOnce(&'f coordinator::Coordinator<DockerBackend>, Req) -> BoxFuture<'f, Result<Resp>>,
 {
-    let coordinator = orchestrator::coordinator::Coordinator::new_docker().await;
+    let coordinator = orchestrator::coordinator::Coordinator::new_docker();
 
     let job = async {
         let req = req.try_into()?;
@@ -675,7 +675,7 @@ struct SandboxCache {
 
 impl SandboxCache {
     async fn crates(&self) -> Result<Stamped<MetaCratesResponse>> {
-        let coordinator = Coordinator::new_docker().await;
+        let coordinator = Coordinator::new_docker();
 
         let c = self
             .crates
@@ -691,7 +691,7 @@ impl SandboxCache {
     }
 
     async fn versions(&self) -> Result<Stamped<MetaVersionsResponse>> {
-        let coordinator = Coordinator::new_docker().await;
+        let coordinator = Coordinator::new_docker();
 
         let v = self
             .versions
@@ -707,7 +707,7 @@ impl SandboxCache {
     }
 
     async fn raw_versions(&self) -> Result<Stamped<Arc<Versions>>> {
-        let coordinator = Coordinator::new_docker().await;
+        let coordinator = Coordinator::new_docker();
 
         let rv = self
             .raw_versions

ui/src/server_axum/websocket.rs

@@ -247,7 +247,7 @@ impl CoordinatorManager {
 
     async fn new() -> Self {
         Self {
-            coordinator: Arc::new(Coordinator::new_docker().await),
+            coordinator: Arc::new(Coordinator::new_docker()),
             tasks: Default::default(),
             semaphore: Arc::new(Semaphore::new(Self::N_PARALLEL)),
             abort_handles: Default::default(),