From 60fa145df77b878c76942b24afbab449830532a2 Mon Sep 17 00:00:00 2001
From: Max Countryman <maxc@me.com>
Date: Tue, 19 Nov 2024 11:16:20 -0800
Subject: [PATCH] instrument scheduler run method

---
 src/scheduler.rs | 11 ++---------
 1 file changed, 2 insertions(+), 9 deletions(-)

diff --git a/src/scheduler.rs b/src/scheduler.rs
index b53df93..eeda3fc 100644
--- a/src/scheduler.rs
+++ b/src/scheduler.rs
@@ -254,6 +254,7 @@ impl<T: Task> Scheduler<T> {
     /// # });
     /// # }
     /// ```
+    #[instrument(skip(self), fields(queue.name = self.queue.name), err)]
     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 {
@@ -301,15 +302,7 @@ impl<T: Task> Scheduler<T> {
         Ok(())
     }
 
-    #[instrument(
-        skip_all,
-        fields(
-            queue.name = self.queue.name,
-            task.id = tracing::field::Empty,
-            until_next
-        ),
-        err
-    )]
+    #[instrument(skip_all, fields(task.id = tracing::field::Empty), err)]
     async fn process_next_schedule(&self, input: &T::Input) -> Result {
         let task_id = self
             .queue