Merge pull request resque#247 from backupify/fix_resque_web_race_condition

Fix resque web race condition

Author: defunkt

lib/resque/server/views/working.erb

@@ -27,8 +27,14 @@
 
 <% else %>
 
-  <% workers = resque.working.reject { |w| w.idle? } %>
-  <h1 class='wi'><%= workers.size %> of <%= resque.workers.size %> Workers Working</h1>
+  <%
+    workers = resque.working
+    jobs = workers.collect {|w| w.job }
+    worker_jobs = workers.zip(jobs)
+    worker_jobs = worker_jobs.reject { |w, j| w.idle? }
+  %>
+
+  <h1 class='wi'><%= worker_jobs.size %> of <%= resque.workers.size %> Workers Working</h1>
   <p class='intro'>The list below contains all workers which are currently running a job.</p>
   <table class='workers'>
     <tr>
@@ -37,15 +43,13 @@
       <th>Queue</th>
       <th>Processing</th>
     </tr>
-    <% if workers.empty? %>
+    <% if worker_jobs.empty? %>
     <tr>
       <td colspan="4" class='no-data'>Nothing is happening right now...</td>
     </tr>
     <% end %>
 
-    <% for worker in workers.sort_by { |w| w.job['run_at'] ? w.job['run_at'] : '' } %>
-      <% job = worker.job %>
-
+    <% worker_jobs.sort_by {|w, j| j['run_at'] ? j['run_at'] : '' }.each do |worker, job| %>
       <tr>
         <td class='icon'><img src="<%=u state = worker.state %>.png" alt="<%= state %>" title="<%= state %>"></td>
         <% host, pid, queues = worker.to_s.split(':') %>