Sha256: 3969619ad742dcfaf3157bdbd2a7aadb169059bde1f45c2e6e6539af8331662b
Contents?: true
Size: 395 Bytes
Versions: 18
Compression:
Stored size: 395 Bytes
Contents
module ResqueWeb
module WorkingHelper
def workers
@workers ||= Resque.workers
end
def jobs
@jobs ||= workers.map(&:job)
end
def worker_jobs
@worker_jobs ||= workers.zip(jobs).reject { |w, j| w.idle? || j['queue'].nil? }
end
def sorted_worker_jobs
@sorted_worker_jobs ||= worker_jobs.sort_by { |w, j| j['run_at'] || '' }
end
end
end
Version data entries
18 entries across 18 versions & 4 rubygems