Class: Resque::Failure::MultipleWithRetrySuppression
- Inherits:
-
Multiple
- Object
- Multiple
- Resque::Failure::MultipleWithRetrySuppression
- Includes:
- Plugins::Retry::Logging
- Defined in:
- lib/resque/failure/multiple_with_retry_suppression.rb
Overview
A multiple failure backend, with retry suppression
For example: if you had a job that could retry 5 times, your failure backends are not notified unless the final retry attempt also fails.
Example:
require 'resque-retry'
require 'resque/failure/redis'
Resque::Failure::MultipleWithRetrySuppression.classes = [Resque::Failure::Redis]
Resque::Failure.backend = Resque::Failure::MultipleWithRetrySuppression
Class Method Summary collapse
-
.failure_key(retry_key) ⇒ Object
Expose this for the hook’s use.
Instance Method Summary collapse
-
#save ⇒ Object
private
Called when the job fails.
Methods included from Plugins::Retry::Logging
Class Method Details
.failure_key(retry_key) ⇒ Object
Expose this for the hook’s use
61 62 63 |
# File 'lib/resque/failure/multiple_with_retry_suppression.rb', line 61 def self.failure_key(retry_key) 'failure-' + retry_key end |
Instance Method Details
#save ⇒ Object
This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.
Called when the job fails
If the job will retry, suppress the failure from the other backends. Store the lastest failure information in redis, used by the web interface.
30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 |
# File 'lib/resque/failure/multiple_with_retry_suppression.rb', line 30 def save 'failure backend save', args_from(payload), exception retryable = retryable? job_being_retried = retryable && if !job_being_retried "#{retryable ? '' : 'non-'}retriable job is not being retried - sending failure to superclass", args_from(payload), exception cleanup_retry_failure_log! super elsif retry_delay > 0 "retry_delay: #{retry_delay} > 0 - saving details in Redis", args_from(payload), exception data = { :failed_at => Time.now.strftime("%Y/%m/%d %H:%M:%S"), :payload => payload, :exception => exception.class.to_s, :error => exception.to_s, :backtrace => Array(exception.backtrace), :worker => worker.to_s, :queue => queue } Resque.redis.setex(failure_key, 2*retry_delay, Resque.encode(data)) else "retry_delay: #{retry_delay} <= 0 - ignoring", args_from(payload), exception end end |