fix: remove excessive persistence logging

Signed-off-by: William Hankins <william@sundae.fi>

Author: whankinsiv

modules/historical_accounts_state/src/historical_accounts_state.rs

@@ -212,13 +212,10 @@ impl HistoricalAccountsState {
                         (state.immutable.clone(), state.config.clone())
                     };
 
-                    info!("sending persist for epoch {}", current_block.epoch);
                     if let Err(e) = persist_tx.send((current_block.epoch as u32, store, cfg)).await
                     {
                         panic!("persistence worker crashed: {e}");
                     }
-
-                    info!("persist send completed");
                 }
             }
 

modules/historical_accounts_state/src/immutable_historical_account_store.rs

@@ -9,7 +9,7 @@ use fjall::{Keyspace, Partition, PartitionCreateOptions};
 use minicbor::{decode, to_vec};
 use rayon::iter::{IntoParallelIterator, ParallelIterator};
 use tokio::sync::Mutex;
-use tracing::{debug, error, info};
+use tracing::{debug, error};
 
 use crate::state::{AccountEntry, ActiveStakeHistory, HistoricalAccountsConfig, RewardHistory};
 
@@ -61,10 +61,14 @@ impl ImmutableHistoricalAccountStore {
     /// and addresses into their respective Fjall partitions for an entire epoch.
     /// Skips any partitions that have already stored the given epoch.
     /// All writes are batched and committed atomically, preventing on-disk corruption in case of failure.
-    pub async fn persist_epoch(&self, epoch: u32, config: &HistoricalAccountsConfig) -> Result<()> {
+    pub async fn persist_epoch(
+        &self,
+        epoch: u32,
+        config: &HistoricalAccountsConfig,
+    ) -> Result<u64> {
         if !config.any_enabled() {
             debug!("no persistence needed for epoch {epoch} (disabled)",);
-            return Ok(());
+            return Ok(0);
         }
 
         let drained_blocks = {
@@ -135,10 +139,7 @@ impl ImmutableHistoricalAccountStore {
         }
 
         match batch.commit() {
-            Ok(_) => {
-                info!("committed {change_count} account changes for epoch {epoch}");
-                Ok(())
-            }
+            Ok(_) => Ok(change_count),
             Err(e) => {
                 error!("batch commit failed for epoch {epoch}: {e}");
                 Err(e.into())