From 89b8bf3c9109cb4f4d775aa35d11d0c8fa663973 Mon Sep 17 00:00:00 2001
From: Max Countryman <maxc@me.com>
Date: Tue, 26 Nov 2024 14:40:08 -0800
Subject: [PATCH] alter trace levels

---
 src/scheduler.rs | 2 +-
 src/worker.rs    | 8 ++++----
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/scheduler.rs b/src/scheduler.rs
index b01025a..a0fa272 100644
--- a/src/scheduler.rs
+++ b/src/scheduler.rs
@@ -258,7 +258,7 @@ impl<T: Task> Scheduler<T> {
     pub async fn run(&self) -> Result {
         let conn = self.queue.pool.acquire().await?;
         let Some(guard) = try_acquire_advisory_lock(conn, &self.queue_lock).await? else {
-            tracing::debug!("Scheduler could not acquire lock, exiting");
+            tracing::trace!("Scheduler could not acquire lock, exiting");
             return Ok(());
         };
 
diff --git a/src/worker.rs b/src/worker.rs
index 8db49a1..622e7df 100644
--- a/src/worker.rs
+++ b/src/worker.rs
@@ -560,7 +560,7 @@ impl<T: Task + Sync> Worker<T> {
     async fn handle_shutdown(&self, processing_tasks: &mut JoinSet<()>) -> Result {
         let task_timeout = self.task.timeout();
 
-        tracing::info!(
+        tracing::debug!(
             task.timeout = ?task_timeout,
             "Waiting for all processing tasks or timeout"
         );
@@ -624,7 +624,7 @@ impl<T: Task + Sync> Worker<T> {
         processing_tasks: &mut JoinSet<()>,
     ) {
         let Ok(permit) = concurrency_limit.try_acquire_owned() else {
-            tracing::debug!("Concurrency limit reached");
+            tracing::trace!("Concurrency limit reached");
             return;
         };
 
@@ -860,7 +860,7 @@ impl<T: Task + Sync> Worker<T> {
         retry_count: RetryCount,
         retry_policy: &RetryPolicy,
     ) -> Result {
-        tracing::info!("Retry policy available, scheduling retry");
+        tracing::debug!("Retry policy available, scheduling retry");
 
         let delay = retry_policy.calculate_delay(retry_count);
         in_progress_task.retry_after(&mut *conn, delay).await?;
@@ -873,7 +873,7 @@ impl<T: Task + Sync> Worker<T> {
         conn: &mut PgConnection,
         in_progress_task: &InProgressTask,
     ) -> Result {
-        tracing::info!("Retry policy exhausted, handling failed task");
+        tracing::debug!("Retry policy exhausted, handling failed task");
 
         in_progress_task.mark_failed(&mut *conn).await?;