ref: cargo fmt

Author: raphael-goetz

crates/base/src/client/mod.rs

@@ -9,7 +9,8 @@ use tonic::{
 use tucana::{
     aquila::{
         RuntimeStatusUpdateRequest, runtime_status_service_client::RuntimeStatusServiceClient,
-    }, shared::ModuleStatus,
+    },
+    shared::ModuleStatus,
 };
 
 pub struct DracoRuntimeStatusService {
@@ -66,20 +67,12 @@ pub async fn create_channel_with_retry(channel_name: &str, url: String) -> Chann
     }
 }
 impl DracoRuntimeStatusService {
-    pub async fn from_url(
-        aquila_url: String,
-        aquila_token: String,
-        identifier: String,
-    ) -> Self {
+    pub async fn from_url(aquila_url: String, aquila_token: String, identifier: String) -> Self {
         let channel = create_channel_with_retry("Aquila", aquila_url).await;
         Self::new(channel, identifier, aquila_token)
     }
 
-    pub fn new(
-        channel: Channel,
-        identifier: String,
-        aquila_token: String,
-    ) -> Self {
+    pub fn new(channel: Channel, identifier: String, aquila_token: String) -> Self {
         DracoRuntimeStatusService {
             channel,
             identifier,

crates/base/src/runner.rs

@@ -1,5 +1,5 @@
 use crate::{
-    client::{DracoRuntimeStatusService},
+    client::DracoRuntimeStatusService,
     config::AdapterConfig,
     store::AdapterStore,
     traits::{LoadConfig, Server as AdapterServer},
@@ -55,10 +55,7 @@ impl<C: LoadConfig> ServerRunner<C> {
         })
     }
 
-    pub async fn serve(
-        self,
-        appendix: Vec<ModuleDefinitionAppendix>,
-    ) -> anyhow::Result<()> {
+    pub async fn serve(self, appendix: Vec<ModuleDefinitionAppendix>) -> anyhow::Result<()> {
         let config = self.context.adapter_config.clone();
         let mut runtime_status_service: Option<Arc<DracoRuntimeStatusService>> = None;
         let mut runtime_status_heartbeat_task: Option<JoinHandle<()>> = None;