From 0a5b9506ae6ccbccc6a2ecde7be227f5a820c221 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Arpad=20M=C3=BCller?= Date: Wed, 2 Apr 2025 16:03:01 +0200 Subject: [PATCH] cargo fmt --- safekeeper/client/src/mgmt_api.rs | 8 ++++++-- storage_controller/src/service/safekeeper_reconciler.rs | 5 ++++- 2 files changed, 10 insertions(+), 3 deletions(-) diff --git a/safekeeper/client/src/mgmt_api.rs b/safekeeper/client/src/mgmt_api.rs index 6c50cd1e35..5849df0343 100644 --- a/safekeeper/client/src/mgmt_api.rs +++ b/safekeeper/client/src/mgmt_api.rs @@ -115,13 +115,17 @@ impl Client { "{}/v1/tenant/{}/timeline/{}", self.mgmt_api_endpoint, tenant_id, timeline_id ); - let resp = self.request_maybe_body(Method::DELETE, &uri, None::<()>).await?; + let resp = self + .request_maybe_body(Method::DELETE, &uri, None::<()>) + .await?; resp.json().await.map_err(Error::ReceiveBody) } pub async fn delete_tenant(&self, tenant_id: TenantId) -> Result { let uri = format!("{}/v1/tenant/{}", self.mgmt_api_endpoint, tenant_id); - let resp = self.request_maybe_body(Method::DELETE, &uri, None::<()>).await?; + let resp = self + .request_maybe_body(Method::DELETE, &uri, None::<()>) + .await?; resp.json().await.map_err(Error::ReceiveBody) } diff --git a/storage_controller/src/service/safekeeper_reconciler.rs b/storage_controller/src/service/safekeeper_reconciler.rs index be3730f23c..76e3162617 100644 --- a/storage_controller/src/service/safekeeper_reconciler.rs +++ b/storage_controller/src/service/safekeeper_reconciler.rs @@ -35,7 +35,10 @@ impl SafekeeperReconcilers { service: &Arc, reqs: Vec, ) { - tracing::info!("Scheduling {} pending safekeeper ops loaded from db", reqs.len()); + tracing::info!( + "Scheduling {} pending safekeeper ops loaded from db", + reqs.len() + ); for req in reqs { self.schedule_request(service, req); }