diff --git a/lib/mini_scheduler/manager.rb b/lib/mini_scheduler/manager.rb
index b722fd5..3b4de7b 100644
--- a/lib/mini_scheduler/manager.rb
+++ b/lib/mini_scheduler/manager.rb
@@ -24,6 +24,7 @@ def initialize(manager)
               end
             end
           end
+
         @keep_alive_thread =
           Thread.new do
             while !@stopped
@@ -31,6 +32,7 @@ def initialize(manager)
               sleep(@manager.keep_alive_duration / 2)
             end
           end
+
         ensure_worker_threads
       end
 
@@ -69,6 +71,7 @@ def ensure_worker_threads
       def worker_loop
         set_current_worker_thread_id!
         keep_alive(current_worker_thread_id)
+
         while !@stopped
           begin
             process_queue
@@ -77,6 +80,7 @@ def worker_loop
               ex,
               message: "Error during MiniScheduler worker_loop",
             )
+
             break # Data could be in a bad state - stop the thread
           end
         end
@@ -142,6 +146,7 @@ def process_queue
           error = "#{e.class}: #{e.message} #{e.backtrace.join("\n")}"
           failed = true
         end
+
         duration = ((Time.now.to_f - start) * 1000).to_i
         info.prev_duration = duration
         info.prev_result = failed ? "FAILED" : "OK"
@@ -158,6 +163,7 @@ def process_queue
         attempts(3) { @mutex.synchronize { info.write! } }
       ensure
         @running = false
+
         if defined?(ActiveRecord::Base)
           ActiveRecord::Base.connection_handler.clear_active_connections!
         end
@@ -366,7 +372,9 @@ def lock
     end
 
     def self.discover_queues
-      ObjectSpace.each_object(MiniScheduler::Schedule).map(&:queue).to_set
+      queues = Set.new
+      ObjectSpace.each_object(MiniScheduler::Schedule).each { |schedule| queues << schedule.queue }
+      queues
     end
 
     def self.discover_schedules