diff options
author | Rafael França <rafaelmfranca@gmail.com> | 2018-08-30 13:39:51 -0500 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-08-30 13:39:51 -0500 |
commit | 5bbaae0d20147d392f1458f1a99d85c245040d04 (patch) | |
tree | 9c894b56328c600ab243547e72794b361b30ea1b /activejob/lib/active_job/logging.rb | |
parent | 5c656889a65e116cf0beb1a059df9d1072aa088f (diff) | |
parent | 3bf33d7c2c3ef3b20173d82bf9af6b953ebc5ff2 (diff) | |
download | rails-5bbaae0d20147d392f1458f1a99d85c245040d04.tar.gz rails-5bbaae0d20147d392f1458f1a99d85c245040d04.tar.bz2 rails-5bbaae0d20147d392f1458f1a99d85c245040d04.zip |
Merge pull request #33751 from steves/add_retry_notifications_to_aj
Add hooks to ActiveJob around retries and discards
Diffstat (limited to 'activejob/lib/active_job/logging.rb')
-rw-r--r-- | activejob/lib/active_job/logging.rb | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/activejob/lib/active_job/logging.rb b/activejob/lib/active_job/logging.rb index 9ffd60ad53..96a3e6bf48 100644 --- a/activejob/lib/active_job/logging.rb +++ b/activejob/lib/active_job/logging.rb @@ -88,6 +88,34 @@ module ActiveJob end end + def enqueue_retry(event) + job = event.payload[:job] + ex = event.payload[:error] + wait = event.payload[:wait] + + error do + "Retrying #{job.class} in #{wait} seconds, due to a #{ex.class}. The original exception was #{ex.cause.inspect}." + end + end + + def retry_stopped(event) + job = event.payload[:job] + ex = event.payload[:error] + + error do + "Stopped retrying #{job.class} due to a #{ex.class}, which reoccurred on #{job.executions} attempts. The original exception was #{ex.cause.inspect}." + end + end + + def discard(event) + job = event.payload[:job] + ex = event.payload[:error] + + error do + "Discarded #{job.class} due to a #{ex.class}. The original exception was #{ex.cause.inspect}." + end + end + private def queue_name(event) event.payload[:adapter].class.name.demodulize.remove("Adapter") + "(#{event.payload[:job].queue_name})" |