Requeue failed jobs from resque-web

Author: michaeldwan

lib/resque/failure.rb

@@ -59,5 +59,8 @@ def self.clear
       backend.clear
     end
 
+    def self.requeue(index)
+      backend.requeue(index)
+    end
   end
 end

lib/resque/failure/base.rb

@@ -48,6 +48,9 @@ def self.url
       # Clear all failure objects
       def self.clear
       end
+      
+      def self.requeue(index)
+      end
 
       # Logging!
       def log(message)

lib/resque/failure/redis.rb

@@ -29,6 +29,12 @@ def self.clear
         Resque.redis.del(:failed)
       end
 
+      def self.requeue(index)
+        item = all(index)
+        item['retried_at'] = Time.now.strftime("%Y/%m/%d %H:%M:%S")
+        Resque.redis.lset(:failed, index, Resque.encode(item))
+        Job.create(item['queue'], item['payload']['class'], *item['payload']['args'])
+      end
     end
   end
 end

lib/resque/server.rb

@@ -129,7 +129,6 @@ def show(page, layout = true)
       Resque.remove_queue(params[:id])
       redirect u('queues')
     end
-    
 
     %w( overview workers ).each do |page|
       get "/#{page}.poll" do
@@ -151,6 +150,11 @@ def show(page, layout = true)
       Resque::Failure.clear
       redirect u('failed')
     end
+    
+    get "/failed/requeue/:index" do
+      Resque::Failure.requeue(params[:index])
+      redirect u('failed')
+    end
 
     get "/stats" do
       redirect url("/stats/resque")

lib/resque/server/public/style.css

@@ -67,6 +67,7 @@ body { padding:0; margin:0; }
 #main ul.failed li {background:-webkit-gradient(linear, left top, left bottom, from(#efefef), to(#fff)) #efefef; margin-top:10px; padding:10px; overflow:hidden; -webkit-border-radius:5px; border:1px solid #ccc; }
 #main ul.failed li dl dt {font-size:80%; color:#999; width:60px; float:left; padding-top:1px; text-align:right;}
 #main ul.failed li dl dd {margin-bottom:10px; margin-left:70px;}
+#main ul.failed li dl dd .retry { float: right; }
 #main ul.failed li dl dd code, #main ul.failed li dl dd pre { font-family:Monaco, "Courier New", monospace; font-size:90%;}
 #main ul.failed li dl dd.error a {font-family:Monaco, "Courier New", monospace; font-size:90%; }
 #main ul.failed li dl dd.error pre { margin-top:3px; line-height:1.3;}

lib/resque/server/views/failed.erb

@@ -1,5 +1,6 @@
 <%start = params[:start].to_i %>
 <%failed = Resque::Failure.all(start, 20)%>
+<% index = 0 %>
 
 <h1>Failed Jobs</h1>
 <%unless failed.empty?%>
@@ -12,10 +13,20 @@
 
 <ul class='failed'>
   <%for job in failed%>
+    <% index += 1 %>
     <li>
       <dl>
         <dt>Worker</dt>
-        <dd><a href="<%= url(:workers, job['worker']) %>"><%= job['worker'].split(':')[0...2].join(':') %></a> on <b class='queue-tag'><%= job['queue'] %></b > at <b><span class="time"><%= job['failed_at'] %></span></b></dd>
+        <dd>
+          <a href="<%= url(:workers, job['worker']) %>"><%= job['worker'].split(':')[0...2].join(':') %></a> on <b class='queue-tag'><%= job['queue'] %></b > at <b><span class="time"><%= job['failed_at'] %></span></b>
+          <div class='retry'>
+            <% if job['retried_at'] %>
+              Retried <b><span class="time"><%= job['retried_at'] %></span></b>
+            <% else %>
+              <a href="<%= u "failed/requeue/#{start + index - 1}" %>">Retry</a>
+            <% end %>
+          </div>
+        </dd>
         <dt>Class</dt>
         <dd><code><%= job['payload']['class'] %></code></dd>
         <dt>Arguments</dt>
@@ -25,7 +36,7 @@
         <dt>Error</dt>
         <dd class='error'>
           <a href="#" class="backtrace"><%= h(job['error']) %></a>
-          <pre style='display:none'><%=h job['backtrace'].join("\n") %></pre>          
+          <pre style='display:none'><%=h job['backtrace'].join("\n") %></pre>
         </dd>
       </dl>
       <div class='r'>