lint

rust/processor/src/processors/account_transactions_processor.rs

@@ -19,7 +19,7 @@ use async_trait::async_trait;
 use diesel::{pg::Pg, query_builder::QueryFragment};
 use rayon::prelude::*;
 use std::fmt::Debug;
-use tracing::{info, error};
+use tracing::{error, info};
 
 pub struct AccountTransactionsProcessor {
     producer: CustomProducerEnum,
@@ -135,7 +135,10 @@ impl ProcessorTrait for AccountTransactionsProcessor {
 
         let network = Network::from_chain_id(_db_chain_id.unwrap_or(0));
         if network.is_none() {
-            bail!("Error getting network from chain id. Processor {}.", self.name())
+            bail!(
+                "Error getting network from chain id. Processor {}.",
+                self.name()
+            )
         }
         let topic_string = format!("aptos.{}.account.transactions", network.unwrap());
         info!(

rust/processor/src/utils/mod.rs

@@ -4,5 +4,5 @@
 pub mod counters;
 pub mod database;
 pub mod mq;
-pub mod util;
 pub mod network;
+pub mod util;

rust/processor/src/utils/network.rs

@@ -23,4 +23,4 @@ impl fmt::Display for Network {
             Network::Testnet => write!(f, "testnet"),
         }
     }
-}
+}

rust/processor/src/worker.rs

@@ -746,8 +746,8 @@ impl Worker {
                 AsyncConnectionWrapper::from(conn);
             run_pending_migrations(&mut conn);
         })
-            .await
-            .expect("[Parser] Failed to run migrations");
+        .await
+        .expect("[Parser] Failed to run migrations");
     }
 
     /// Gets the start version for the processor. If not found, start from 0.