class Delayed::Heartbeat::DeleteWorkerResults
Public Class Methods
new(worker_job_map)
click to toggle source
# File lib/delayed/heartbeat/delete_worker_results.rb, line 6 def initialize(worker_job_map) @worker_job_map = worker_job_map end
Public Instance Methods
empty?()
click to toggle source
# File lib/delayed/heartbeat/delete_worker_results.rb, line 18 def empty? @worker_job_map.empty? end
to_s()
click to toggle source
# File lib/delayed/heartbeat/delete_worker_results.rb, line 22 def to_s io = StringIO.new workers.each do |worker| worker_description = "#{worker.label}(#{worker.name})" io.puts("Deleted worker #{worker_description}") unlocked_jobs(worker).each do |unlocked_job| io.puts("Unlocked orphaned job #{unlocked_job.id} from worker #{worker_description}") end end io.string.rstrip end
unlocked_jobs(worker = nil)
click to toggle source
# File lib/delayed/heartbeat/delete_worker_results.rb, line 14 def unlocked_jobs(worker = nil) worker ? @worker_job_map.fetch(worker, []) : @worker_job_map.values.flatten end
workers()
click to toggle source
# File lib/delayed/heartbeat/delete_worker_results.rb, line 10 def workers @worker_job_map.keys end