<% if params[:id] && (worker = Resque::Worker.find(params[:id])) && worker.job %>
<%= worker %>'s job
| |
Where |
Queue |
Started |
Class |
Args |
 |
<% host, pid, _ = worker.to_s.split(':') %>
"><%= host %>:<%= pid %> |
<% data = worker.job %>
<% queue = data['queue'] %>
"><%= queue %> |
<%= data['run_at'] %> |
<%= data['payload']['class'] %>
|
<%=h data['payload']['args'].inspect %> |
<% else %>
<%
workers = resque.working
jobs = workers.collect {|w| w.job }
worker_jobs = workers.zip(jobs)
worker_jobs = worker_jobs.reject { |w, j| w.idle? }
%>
<%= worker_jobs.size %> of <%= resque.workers.size %> Workers Working
The list below contains all workers which are currently running a job.
| |
Where |
Queue |
Processing |
<% if worker_jobs.empty? %>
| Nothing is happening right now... |
<% end %>
<% worker_jobs.sort_by {|w, j| j['run_at'] ? j['run_at'] : '' }.each do |worker, job| %>
 |
<% host, pid, queues = worker.to_s.split(':') %>
"><%= host %>:<%= pid %> |
"><%= job['queue'] %>
|
<% if job['queue'] %>
<%= job['payload']['class'] %>
"><%= job['run_at'] %>
<% else %>
Waiting for a job...
<% end %>
|
<% end %>
<% end %>