% if params[:id] && (worker = find_worker(params[:id])) && !worker.job.empty? %>
Where (ip):pid:thread:path | Queue | Started | Class | Args | |
---|---|---|---|---|---|
<% host, pid,thread, path, _ = worker.to_s.split(':') %> | <%= link_to("#{host}:#{pid}:#{thread}:#{path}", {:action => 'workers', :id => worker.to_s.gsub(/\./,'_')}) %> | <% data = worker.job %> <% queue = data['queue'] %><%= link_to(queue, {:action => 'queues', :id => queue}, :class => 'queue') %> | <%= format_time(Time.zone.parse(data['run_at'].to_s)) %> |
<%= data['payload']['class'] %>
|
<%= data['payload']['args'].inspect.html_safe %> |
The list below contains all workers which are currently running a job.
Where (ip):pid:thread:path | Queue | Processing | |
---|---|---|---|
Nothing is happening right now... | |||
.png" alt="<%= state %>" title="<%= state %>"> | <% host, pid, thread, path, queues = worker.to_s.split(':') %><%= link_to("#{host}:#{pid}:#{thread}:#{path}", {:action => 'workers', :id => worker.to_s.gsub(/\./,'_')}) %> | <%= link_to(job['queue'], {:action => 'queues', :id => job['queue']}, :class => 'queue-tag') %> |
<% if job['queue'] %>
<%= job['payload']['class'] %>
<%= link_to(format_time(Time.zone.parse(job['run_at'].to_s)), {:action => 'working', :id => worker.to_s.gsub(/\./,'_')}, :class => 'queue time') %>
<%=worker.overview_message%> <% else %> Waiting for a job... <% end %> |