fix processor name

aptos-labs · Jul 25, 2024 · 96228f8 · 96228f8
1 parent 6a481af
commit 96228f8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/rust/processor/src/processors/mod.rs b/rust/processor/src/processors/mod.rs
@@ -215,8 +215,7 @@ impl ProcessorConfig {
             ProcessorConfig::ParquetDefaultProcessor(_)
                 | ProcessorConfig::ParquetFungibleAssetProcessor(_)
                 | ProcessorConfig::ParquetTransactionMetadataProcessor(_)
-                            | ProcessorConfig::ParquetAnsProcessor(_)
-
+                | ProcessorConfig::ParquetAnsProcessor(_)
         )
     }
 }

diff --git a/rust/processor/src/processors/parquet_processors/parquet_ans_processor.rs b/rust/processor/src/processors/parquet_processors/parquet_ans_processor.rs
@@ -82,19 +82,18 @@ impl ParquetAnsProcessor {
 
 impl Debug for ParquetAnsProcessor {
     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
-        let state = &self.connection_pool.state();
         write!(
             f,
-            "AnsProcessor {{ connections: {:?}  idle_connections: {:?} }}",
-            state.connections, state.idle_connections
+            "ParquetAnsProcessor {{ capacity of trnasactions channel: {:?}}}",
+            &self.ans_primary_name_v2_sender.capacity()
         )
     }
 }
 
 #[async_trait]
 impl ProcessorTrait for ParquetAnsProcessor {
     fn name(&self) -> &'static str {
-        ProcessorName::AnsProcessor.into()
+        ProcessorName::ParquetAnsProcessor.into()
     }
 
     async fn process_transactions(