feature: подавление ошибок resque-retry

https://jira.railsc.ru/browse/SERVICES-766 https://jira.railsc.ru/browse/SERVICES-656
abak-press · Apr 18, 2016 · e254f48 · e254f48
1 parent 745a3a7
commit e254f48
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 1 deletion.
diff --git a/lib/resque/integration/engine.rb b/lib/resque/integration/engine.rb
@@ -65,6 +65,18 @@ class Engine < Rails::Engine
       end
     end
 
+    # Глушим ошибки, по которым происходит автоматический перезапуск
+    initializer 'resque-integration.retrys' do
+      if Resque.config.failure_notifier.enabled?
+        require 'resque_failed_job_mailer'
+        require 'resque/failure'
+        require 'resque/failure/redis'
+
+        Resque::Failure::MultipleWithRetrySuppression.classes = [Resque::Failure::Redis, Resque::Failure::Notifier]
+        Resque::Failure.backend = Resque::Failure::MultipleWithRetrySuppression
+      end
+    end
+
     initializer "resque-integration.extensions" do
       ::Resque::Worker.send :include, ::Resque::Integration::Extensions::Worker
     end

diff --git a/resque-integration.gemspec b/resque-integration.gemspec
@@ -27,7 +27,7 @@ Gem::Specification.new do |gem|
   gem.add_runtime_dependency 'resque-multi-job-forks', '~> 0.4.2'
   gem.add_runtime_dependency 'resque-failed-job-mailer', '~> 0.0.3'
   gem.add_runtime_dependency 'resque-scheduler', '~> 4.0'
-  gem.add_runtime_dependency 'resque-retry', '~> 1.3'
+  gem.add_runtime_dependency 'resque-retry', '~> 1.5'
   gem.add_runtime_dependency 'god', '~> 0.13.4'
 
   gem.add_runtime_dependency 'multi_json'