cargo fmt

Mark generated modules in nexus/pt with `rustfmt::skip`
PeerDB-io · Nov 2, 2023 · 99448ba · 99448ba
1 parent de9ceff
commit 99448ba
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 7 deletions.
diff --git a/nexus/analyzer/src/lib.rs b/nexus/analyzer/src/lib.rs
@@ -154,12 +154,8 @@ impl<'a> StatementAnalyzer for PeerDDLAnalyzer<'a> {
                         let mut flow_job_table_mappings = vec![];
                         for table_mapping in &cdc.mapping_options {
                             flow_job_table_mappings.push(FlowJobTableMapping {
-                                source_table_identifier: table_mapping
-                                    .source
-                                    .to_string(),
-                                destination_table_identifier: table_mapping
-                                    .destination
-                                    .to_string(),
+                                source_table_identifier: table_mapping.source.to_string(),
+                                destination_table_identifier: table_mapping.destination.to_string(),
                                 partition_key: table_mapping
                                     .partition_key
                                     .clone()

diff --git a/nexus/flow-rs/src/grpc.rs b/nexus/flow-rs/src/grpc.rs
@@ -81,7 +81,7 @@ impl FlowGrpcClient {
     ) -> anyhow::Result<String> {
         let create_qrep_flow_req = pt::peerdb_route::CreateQRepFlowRequest {
             qrep_config: Some(qrep_config.clone()),
-            create_catalog_entry:false
+            create_catalog_entry: false,
         };
         let response = self.client.create_q_rep_flow(create_qrep_flow_req).await?;
         let workflow_id = response.into_inner().worflow_id;

diff --git a/nexus/pt/src/lib.rs b/nexus/pt/src/lib.rs
@@ -4,8 +4,11 @@ use peerdb_peers::DbType;
 use sqlparser::ast::PeerType;
 
 pub mod flow_model;
+#[rustfmt::skip]
 pub mod peerdb_flow;
+#[rustfmt::skip]
 pub mod peerdb_peers;
+#[rustfmt::skip]
 pub mod peerdb_route;
 
 impl From<PeerType> for DbType {