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