From a067939607abd4886761b6e267e24276632a9b8a Mon Sep 17 00:00:00 2001 From: Tommy Graves Date: Fri, 13 Dec 2024 11:28:09 -0500 Subject: [PATCH] Move some of the noisier traces back to log-level 'trace' (#111) --- Cargo.lock | 2 +- crates/abq_cli/Cargo.toml | 2 +- crates/abq_queue/src/persistence/results.rs | 2 +- crates/abq_queue/src/queue.rs | 2 +- 4 files changed, 4 insertions(+), 4 deletions(-) diff --git a/Cargo.lock b/Cargo.lock index b0544afa..51bbd0a5 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -4,7 +4,7 @@ version = 3 [[package]] name = "abq" -version = "1.9.1" +version = "1.9.2" dependencies = [ "abq_dot_reporter", "abq_hosted", diff --git a/crates/abq_cli/Cargo.toml b/crates/abq_cli/Cargo.toml index be4c5928..1ab6d222 100644 --- a/crates/abq_cli/Cargo.toml +++ b/crates/abq_cli/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "abq" -version = "1.9.1" +version = "1.9.2" edition = "2021" [dependencies] diff --git a/crates/abq_queue/src/persistence/results.rs b/crates/abq_queue/src/persistence/results.rs index 2325c478..373f32bf 100644 --- a/crates/abq_queue/src/persistence/results.rs +++ b/crates/abq_queue/src/persistence/results.rs @@ -189,7 +189,7 @@ pub struct PersistencePlan<'a> { } impl<'a> PersistencePlan<'a> { - #[tracing::instrument(level = "info", skip_all, fields(run_id = %self.cell.run_id, eligible_for_remote_dump = %self.eligible_for_remote_dump.bool()))] + #[tracing::instrument(level = "trace", skip_all, fields(run_id = %self.cell.run_id, eligible_for_remote_dump = %self.eligible_for_remote_dump.bool()))] pub async fn execute(self) -> Result<()> { let result = self .persist_results diff --git a/crates/abq_queue/src/queue.rs b/crates/abq_queue/src/queue.rs index 0d28f4dd..177f1ba9 100644 --- a/crates/abq_queue/src/queue.rs +++ b/crates/abq_queue/src/queue.rs @@ -2260,7 +2260,7 @@ impl QueueServer { Ok(()) } - #[instrument(level = "info", skip_all, fields(run_id=%run_id, entity=?entity, results_message_size=%results_message_size))] + #[instrument(level = "trace", skip_all, fields(run_id=%run_id, entity=?entity, results_message_size=%results_message_size))] async fn handle_worker_results( queues: SharedRuns, persist_results: SharedPersistResults,