Move some of the noisier traces back to log-level 'trace' (#111)

TAGraves · web-flow · commit a067939607ab · 2024-12-13T11:28:09.000-05:00
diff --git a/Cargo.lock b/Cargo.lock
diff --git 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
@@ -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
@@ -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,

Original file line number	Diff line number	Diff line change
`@@ -189,7 +189,7 @@ pub struct PersistencePlan<'a> {`
`189`	`189`	`}`
`190`	`190`
`191`	`191`	`impl<'a> PersistencePlan<'a> {`
`192`		`- #[tracing::instrument(level = "info", skip_all, fields(run_id = %self.cell.run_id, eligible_for_remote_dump = %self.eligible_for_remote_dump.bool()))]`
	`192`	`+ #[tracing::instrument(level = "trace", skip_all, fields(run_id = %self.cell.run_id, eligible_for_remote_dump = %self.eligible_for_remote_dump.bool()))]`
`193`	`193`	`pub async fn execute(self) -> Result<()> {`
`194`	`194`	`let result = self`
`195`	`195`	`.persist_results`
Original file line number	Diff line number	Diff line change
`@@ -2260,7 +2260,7 @@ impl QueueServer {`
`2260`	`2260`	`Ok(())`
`2261`	`2261`	`}`
`2262`	`2262`
`2263`		`- #[instrument(level = "info", skip_all, fields(run_id=%run_id, entity=?entity, results_message_size=%results_message_size))]`
	`2263`	`+ #[instrument(level = "trace", skip_all, fields(run_id=%run_id, entity=?entity, results_message_size=%results_message_size))]`
`2264`	`2264`	`async fn handle_worker_results(`
`2265`	`2265`	`queues: SharedRuns,`
`2266`	`2266`	`persist_results: SharedPersistResults,`