diff --git a/crates/federate/src/lib.rs b/crates/federate/src/lib.rs index b6c820aaa..382aa59b8 100644 --- a/crates/federate/src/lib.rs +++ b/crates/federate/src/lib.rs @@ -154,7 +154,6 @@ async fn receive_print_stats( tokio::select! { ele = receiver.recv() => { let Some((domain, ele)) = ele else { - tracing::info!("done. quitting"); print_stats(pool, &stats).await; return; }; @@ -181,9 +180,9 @@ async fn print_stats(pool: &mut DbPool<'_>, stats: &HashMap 0 { @@ -195,10 +194,11 @@ async fn print_stats(pool: &mut DbPool<'_>, stats: &HashMap 0 { - tracing::info!("{}: Ok. {} behind", domain, behind); + tracing::debug!("{}: Ok. {} activities behind", domain, behind); + behind_count += 1; } else { ok_count += 1; } } - tracing::info!("{ok_count} others up to date"); + tracing::info!("{ok_count} others up to date. {behind_count} instances behind."); } diff --git a/crates/federate/src/worker.rs b/crates/federate/src/worker.rs index ad2b5b7d2..a383d61b2 100644 --- a/crates/federate/src/worker.rs +++ b/crates/federate/src/worker.rs @@ -221,7 +221,7 @@ impl InstanceWorker { SendActivityTask::prepare(object, actor.as_ref(), inbox_urls, &self.context).await?; for task in requests { // usually only one due to shared inbox - tracing::info!("sending out {}", task); + tracing::debug!("sending out {}", task); while let Err(e) = task.sign_and_send(&self.context).await { self.state.fail_count += 1; self.state.last_retry = Some(Utc::now());