Retry delete when deadlocked

Fixes collectiveidea#63
TeachingChannel · Sep 24, 2015 · 865a8f8 · 865a8f8
1 parent 270b06e
commit 865a8f8
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/lib/delayed/backend/active_record.rb b/lib/delayed/backend/active_record.rb
@@ -121,6 +121,20 @@ def reload(*args)
           reset
           super
         end
+
+        def destroy
+          retries = 0
+          begin
+            super
+          rescue ::ActiveRecord::StatementInvalid => e
+            if e.message =~ /Deadlock found when trying to get lock/ && retries < 100
+              retries +=1
+              retry
+            else
+              raise
+            end
+          end
+        end
       end
     end
   end