diff options
| author | David Heinemeier Hansson <david@loudthinking.com> | 2016-08-16 16:01:59 -0700 |
|---|---|---|
| committer | David Heinemeier Hansson <david@loudthinking.com> | 2016-08-16 16:01:59 -0700 |
| commit | a1e4c197cb12fef66530a2edfaeda75566088d1f (patch) | |
| tree | de37b052b4cea329b94f0f8dfb633b99564d04a6 /activejob/lib/active_job/exceptions.rb | |
| parent | e1aabeedd896fe381570f85c5b4116049c49f1b6 (diff) | |
| download | rails-a1e4c197cb12fef66530a2edfaeda75566088d1f.tar.gz rails-a1e4c197cb12fef66530a2edfaeda75566088d1f.tar.bz2 rails-a1e4c197cb12fef66530a2edfaeda75566088d1f.zip | |
Yield the job instance so you have access to things like `job.arguments` on the custom logic after retries fail
Diffstat (limited to 'activejob/lib/active_job/exceptions.rb')
| -rw-r--r-- | activejob/lib/active_job/exceptions.rb | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/activejob/lib/active_job/exceptions.rb b/activejob/lib/active_job/exceptions.rb index a8ff55fbe4..f8d76587ad 100644 --- a/activejob/lib/active_job/exceptions.rb +++ b/activejob/lib/active_job/exceptions.rb @@ -12,7 +12,7 @@ module ActiveJob # holding queue for inspection. # # You can also pass a block that'll be invoked if the retry attempts fail for custom logic rather than letting - # the exception bubble up. + # the exception bubble up. This block is yielded with the job instance as the first and the error instance as the second parameter. # # ==== Options # * <tt>:wait</tt> - Re-enqueues the job with a delay specified either in seconds (default: 3 seconds), @@ -28,7 +28,7 @@ module ActiveJob # class RemoteServiceJob < ActiveJob::Base # retry_on CustomAppException # defaults to 3s wait, 5 attempts # retry_on AnotherCustomAppException, wait: ->(executions) { executions * 2 } - # retry_on(YetAnotherCustomAppException) do |exception| + # retry_on(YetAnotherCustomAppException) do |job, exception| # ExceptionNotifier.caught(exception) # end # retry_on ActiveRecord::StatementInvalid, wait: 5.seconds, attempts: 3 @@ -47,7 +47,7 @@ module ActiveJob retry_job wait: determine_delay(wait), queue: queue, priority: priority else if block_given? - yield exception + yield self, exception else logger.error "Stopped retrying #{self.class} due to a #{exception}, which reoccurred on #{executions} attempts. The original exception was #{error.cause.inspect}." raise error |