cargo fmt

PeerDB-io · Apr 26, 2024 · 54a99c9 · 54a99c9
1 parent 66c88b4
commit 54a99c9
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 6 deletions.
diff --git a/nexus/analyzer/src/lib.rs b/nexus/analyzer/src/lib.rs
@@ -164,8 +164,10 @@ impl StatementAnalyzer for PeerDDLAnalyzer {
             } => {
                 match create_mirror {
                     CDC(cdc) => {
-                        let flow_job_table_mappings = cdc.mapping_options.iter().map(|table_mapping|
-                            FlowJobTableMapping {
+                        let flow_job_table_mappings = cdc
+                            .mapping_options
+                            .iter()
+                            .map(|table_mapping| FlowJobTableMapping {
                                 source_table_identifier: table_mapping.source.to_string(),
                                 destination_table_identifier: table_mapping.destination.to_string(),
                                 partition_key: table_mapping
@@ -177,8 +179,8 @@ impl StatementAnalyzer for PeerDDLAnalyzer {
                                     .as_ref()
                                     .map(|ss| ss.iter().map(|s| s.value.clone()).collect())
                                     .unwrap_or_default(),
-                            }
-                        ).collect::<Vec<_>>();
+                            })
+                            .collect::<Vec<_>>();
 
                         // get do_initial_copy from with_options
                         let mut raw_options = HashMap::with_capacity(cdc.with_options.len());

diff --git a/nexus/server/src/main.rs b/nexus/server/src/main.rs
@@ -188,7 +188,9 @@ impl NexusBackend {
             flow_handler.as_ref()
         } else {
             return Ok(());
-        }.lock().await;
+        }
+        .lock()
+        .await;
 
         let validate_request = pt::peerdb_route::ValidatePeerRequest {
             peer: Some(Peer {
@@ -779,7 +781,8 @@ impl NexusBackend {
             }
 
             NexusStatement::Rollback { stmt } => {
-                self.execute_statement(self.catalog.as_ref(), &stmt, None).await
+                self.execute_statement(self.catalog.as_ref(), &stmt, None)
+                    .await
             }
 
             NexusStatement::Empty => Ok(vec![Response::EmptyQuery]),