rescue Failing jobs and keep stats on it

Author: Aaron Patterson and Terence Lee

lib/resque/consumer.rb

@@ -47,7 +47,12 @@ def consume
         if job == POISON
           shutdown
         else
-          job.run
+          begin
+            job.run
+          rescue Exception
+            # run failure hooks
+            Stat << "failed"
+          end
         end
       end
     end

test/consumer_test.rb

@@ -14,6 +14,12 @@ def run
       end
     end
 
+    class FailingJob
+      def run
+        raise "fuuuu"
+      end
+    end
+
     class Resumer
       LATCHES = {}
 
@@ -130,5 +136,14 @@ def run
       assert_equal 1, q.length
       assert_equal 0, Actionable.ran.length
     end
+
+    it "gracefully handles a job failure" do
+      q = Queue.new(:foo)
+      c = Consumer.new(q, 1)
+      q << FailingJob.new
+      q << Poison.new(c)
+      c.consume
+      assert_equal 1, Stat["failed"], 'should have one fail'
+    end
   end
 end