From 50041b20111f1b580521a914f93dbe9a6bfcc1f1 Mon Sep 17 00:00:00 2001
From: rob <robacarp@users.noreply.github.com>
Date: Thu, 31 Oct 2024 09:17:19 -0600
Subject: [PATCH] cleans up log calls in runners

---
 src/mosquito/runnable.cr            | 4 +++-
 src/mosquito/runners/coordinator.cr | 2 +-
 src/mosquito/runners/executor.cr    | 4 ----
 src/mosquito/runners/overseer.cr    | 3 +--
 src/mosquito/runners/queue_list.cr  | 8 +++-----
 5 files changed, 8 insertions(+), 13 deletions(-)

diff --git a/src/mosquito/runnable.cr b/src/mosquito/runnable.cr
index de99f8ce..67169bff 100644
--- a/src/mosquito/runnable.cr
+++ b/src/mosquito/runnable.cr
@@ -100,6 +100,8 @@ module Mosquito
       "#{self.class.name.underscore.gsub("::", ".")}.#{self.object_id}"
     }
 
+    private getter log : ::Log { Log.for runnable_name }
+
     private def state=(state : State)
       @state = state
     end
@@ -156,7 +158,7 @@ module Mosquito
         end
         notifier.send state.finished?
 
-        Log.info { runnable_name + " has stopped" }
+        log.info { runnable_name + " has stopped" }
       end
 
       notifier
diff --git a/src/mosquito/runners/coordinator.cr b/src/mosquito/runners/coordinator.cr
index 75c050b9..6f3100e6 100644
--- a/src/mosquito/runners/coordinator.cr
+++ b/src/mosquito/runners/coordinator.cr
@@ -14,7 +14,7 @@ module Mosquito::Runners
     end
 
     def runnable_name : String
-      "Coordinator<#{object_id}>"
+      "coordinator.#{object_id}"
     end
 
     def schedule : Nil
diff --git a/src/mosquito/runners/executor.cr b/src/mosquito/runners/executor.cr
index ff9dbc21..5d8750d8 100644
--- a/src/mosquito/runners/executor.cr
+++ b/src/mosquito/runners/executor.cr
@@ -24,9 +24,6 @@ module Mosquito::Runners
     include RunAtMost
     include Runnable
 
-    Log = ::Log.for self
-    getter log : ::Log
-
     # How long a job config is persisted after success
     property successful_job_ttl : Int32 { Mosquito.configuration.successful_job_ttl }
 
@@ -53,7 +50,6 @@ module Mosquito::Runners
     end
 
     def initialize(@job_pipeline, @idle_bell)
-      @log = Log.for(object_id.to_s)
     end
 
     # :nodoc:
diff --git a/src/mosquito/runners/overseer.cr b/src/mosquito/runners/overseer.cr
index 5d15b11f..d6c872ec 100644
--- a/src/mosquito/runners/overseer.cr
+++ b/src/mosquito/runners/overseer.cr
@@ -16,7 +16,6 @@ module Mosquito::Runners
     include RunAtMost
     include Runnable
 
-    getter log : ::Log { Log.for(runnable_name) }
     getter observer : Observability::Overseer { Observability::Overseer.new(self) }
 
     getter queue_list : QueueList
@@ -61,7 +60,7 @@ module Mosquito::Runners
     end
 
     def runnable_name : String
-      "overseer.#{object_id}"
+      "overseer"
     end
 
     def sleep
diff --git a/src/mosquito/runners/queue_list.cr b/src/mosquito/runners/queue_list.cr
index 3516f3c8..cedb707a 100644
--- a/src/mosquito/runners/queue_list.cr
+++ b/src/mosquito/runners/queue_list.cr
@@ -5,8 +5,6 @@ require "./idle_wait"
 module Mosquito::Runners
   # QueueList handles searching the redis keyspace for named queues.
   class QueueList
-    Log = ::Log.for self
-
     include RunAtMost
     include Runnable
     include IdleWait
@@ -18,7 +16,7 @@ module Mosquito::Runners
     end
 
     def runnable_name : String
-      "QueueList<#{object_id}>"
+      "queue-list"
     end
 
     delegate each, to: @queues.shuffle
@@ -33,7 +31,7 @@ module Mosquito::Runners
         candidate_queues = Mosquito.backend.list_queues.map { |name| Queue.new name }
         new_queue_list = filter_queues candidate_queues
 
-        Log.notice {
+        log.notice {
           queues_which_were_expected_but_not_found = @queues - new_queue_list
           queues_which_have_never_been_seen = new_queue_list - @queues
 
@@ -55,7 +53,7 @@ module Mosquito::Runners
         permitted_queues.includes? queue.name
       end
 
-      Log.for("filter_queues").notice {
+      log.for("filter_queues").notice {
         if filtered_queues.empty?
           filtered_out_queues = present_queues - filtered_queues