fmt

Signed-off-by: Bugen Zhao <[email protected]>
risingwavelabs · Jan 19, 2024 · c9833c5 · c9833c5
1 parent 52c9b79
commit c9833c5
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/src/meta/service/src/cloud_service.rs b/src/meta/service/src/cloud_service.rs
@@ -22,7 +22,7 @@ use risingwave_connector::source::kafka::private_link::insert_privatelink_broker
 use risingwave_connector::source::{
     ConnectorProperties, SourceEnumeratorContext, SourceProperties, SplitEnumerator,
 };
-use risingwave_meta::manager::{MetadataManager, ConnectionId};
+use risingwave_meta::manager::{ConnectionId, MetadataManager};
 use risingwave_pb::catalog::connection::Info::PrivateLinkService;
 use risingwave_pb::cloud_service::cloud_service_server::CloudService;
 use risingwave_pb::cloud_service::rw_cloud_validate_source_response::{Error, ErrorType};
@@ -79,7 +79,10 @@ impl CloudService for CloudServiceImpl {
         // broker rewrite map currently only support aws privatelink connection
         if let Some(connection_id_str) = source_cfg.get("connection.id") {
             let connection_id = connection_id_str.parse::<ConnectionId>().map_err(|e| {
-                Status::invalid_argument(format!("connection.id is not an integer: {}", e.as_report()))
+                Status::invalid_argument(format!(
+                    "connection.id is not an integer: {}",
+                    e.as_report()
+                ))
             })?;
 
             let connection = match &self.metadata_manager {

diff --git a/src/meta/src/backup_restore/utils.rs b/src/meta/src/backup_restore/utils.rs
@@ -75,8 +75,7 @@ pub async fn get_meta_store(opts: RestoreOpts) -> BackupResult<MetaStoreBackendI
             }
             let client = EtcdClient::connect(endpoints, Some(options), credentials.is_some())
                 .await
-                .context("failed to connect etcd")
-?;
+                .context("failed to connect etcd")?;
             Ok(MetaStoreBackendImpl::Etcd(EtcdMetaStore::new(client)))
         }
         MetaStoreBackend::Mem => Ok(MetaStoreBackendImpl::Mem(MemStore::new())),