ForgeFlux/activitypub-federation-rust
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Improved logging for activity send

Browse source
This commit is contained in:
Felix Ableitner 2023-05-04 23:56:27 +02:00
parent 7885e51599
commit 9df5bd086f
1 changed files with 5 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/activity_queue.rs
View file

@ -94,7 +94,7 @@ where
} else { } else {
activity_queue.queue(message).await?; activity_queue.queue(message).await?;
let stats = activity_queue.get_stats().await?; let stats = activity_queue.get_stats().await?;
info!( let stats_fmt = format!(
"Activity queue stats: pending: {}, running: {}, dead (this hour): {}, complete (this hour): {}", "Activity queue stats: pending: {}, running: {}, dead (this hour): {}, complete (this hour): {}",
stats.pending, stats.pending,
stats.running, stats.running,
@ -102,7 +102,10 @@ where
stats.complete.this_hour() stats.complete.this_hour()
); );
if stats.running as u64 == config.worker_count { 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);
} }
} }
} }