From d23bb61cb677ab881e41430853df6e0b521d7258 Mon Sep 17 00:00:00 2001 From: Astro Date: Mon, 30 Oct 2023 00:36:01 +0100 Subject: [PATCH] hunter/worker: log with stats_key to differentiate "stream_token" --- hunter/src/worker.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hunter/src/worker.rs b/hunter/src/worker.rs index ac90392..95490db 100644 --- a/hunter/src/worker.rs +++ b/hunter/src/worker.rs @@ -128,14 +128,14 @@ pub async fn run( // Process stream let (mut new_post_ratio, mut mean_interval) = timeline_result.unwrap_or((None, None)); if let Ok((stats_key, stream)) = stream_result { - tracing::info!("Processing stream for {}", &host.host); + tracing::info!("Processing {stats_key} for {}", &host.host); metrics::increment_gauge!("hunter_requests", 1.0, "type" => stats_key); let start_time = Instant::now(); let post_count = stream.await; let end_time = Instant::now(); metrics::decrement_gauge!("hunter_requests", 1.0, "type" => stats_key); - tracing::warn!("Ended stream for {}. {} posts in {:?}", &host.host, post_count, end_time - start_time); + tracing::warn!("Ended {stats_key} for {}. {} posts in {:?}", &host.host, post_count, end_time - start_time); if post_count > 0 { if let Some(ref mut new_post_ratio) = new_post_ratio {