From 9df5bd086f3ea127f5906f31441c388ce79c8cc0 Mon Sep 17 00:00:00 2001 From: Felix Ableitner Date: Thu, 4 May 2023 23:56:27 +0200 Subject: [PATCH] Improved logging for activity send --- src/activity_queue.rs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/activity_queue.rs b/src/activity_queue.rs index dcc8fa3..630c66b 100644 --- a/src/activity_queue.rs +++ b/src/activity_queue.rs @@ -94,7 +94,7 @@ where } else { activity_queue.queue(message).await?; let stats = activity_queue.get_stats().await?; - info!( + let stats_fmt = format!( "Activity queue stats: pending: {}, running: {}, dead (this hour): {}, complete (this hour): {}", stats.pending, stats.running, @@ -102,7 +102,10 @@ where stats.complete.this_hour() ); if stats.running as u64 == config.worker_count { - warn!("Maximum number of activitypub workers reached. Consider increasing worker count to avoid federation delays"); + warn!("Reached max number of send activity workers ({}). Consider increasing worker count to avoid federation delays", config.worker_count); + warn!(stats_fmt); + } else { + info!(stats_fmt); } } }