aboutsummaryrefslogtreecommitdiffstats
path: root/activejob/test
diff options
context:
space:
mode:
Diffstat (limited to 'activejob/test')
-rw-r--r--activejob/test/cases/exceptions_test.rb39
-rw-r--r--activejob/test/jobs/retry_job.rb4
2 files changed, 43 insertions, 0 deletions
diff --git a/activejob/test/cases/exceptions_test.rb b/activejob/test/cases/exceptions_test.rb
index f6ca528362..0bc1d82623 100644
--- a/activejob/test/cases/exceptions_test.rb
+++ b/activejob/test/cases/exceptions_test.rb
@@ -1,5 +1,6 @@
require 'helper'
require 'jobs/retry_job'
+require 'byebug'
class ExceptionsTest < ActiveSupport::TestCase
setup do
@@ -45,3 +46,41 @@ class ExceptionsTest < ActiveSupport::TestCase
assert_equal "Raised DiscardableError for the 1st time", JobBuffer.last_value
end
end
+
+class ExponentiallyBackoffExceptionsTest < ActiveJob::TestCase
+ setup do
+ JobBuffer.clear
+ end
+
+ test "exponentially retrying job" do
+ travel_to Time.now
+
+ perform_enqueued_jobs do
+ assert_performed_with at: (Time.now + 3.seconds).to_i do
+ assert_performed_with at: (Time.now + 18.seconds).to_i do
+ assert_performed_with at: (Time.now + 83.seconds).to_i do
+ assert_performed_with at: (Time.now + 258.seconds).to_i do
+ RetryJob.perform_later 'ExponentialWaitTenAttemptsError', 5
+ end
+ end
+ end
+ end
+ end
+ end
+
+ test "custom wait retrying job" do
+ travel_to Time.now
+
+ perform_enqueued_jobs do
+ assert_performed_with at: (Time.now + 2.seconds).to_i do
+ assert_performed_with at: (Time.now + 4.seconds).to_i do
+ assert_performed_with at: (Time.now + 6.seconds).to_i do
+ assert_performed_with at: (Time.now + 8.seconds).to_i do
+ RetryJob.perform_later 'CustomWaitTenAttemptsError', 5
+ end
+ end
+ end
+ end
+ end
+ end
+end \ No newline at end of file
diff --git a/activejob/test/jobs/retry_job.rb b/activejob/test/jobs/retry_job.rb
index 91be37f106..35177c5be5 100644
--- a/activejob/test/jobs/retry_job.rb
+++ b/activejob/test/jobs/retry_job.rb
@@ -3,11 +3,15 @@ require 'active_support/core_ext/integer/inflections'
class DefaultsError < StandardError; end
class ShortWaitTenAttemptsError < StandardError; end
+class ExponentialWaitTenAttemptsError < StandardError; end
+class CustomWaitTenAttemptsError < StandardError; end
class DiscardableError < StandardError; end
class RetryJob < ActiveJob::Base
retry_on DefaultsError
retry_on ShortWaitTenAttemptsError, wait: 1.second, attempts: 10
+ retry_on ExponentialWaitTenAttemptsError, wait: :exponentially_longer, attempts: 10
+ retry_on CustomWaitTenAttemptsError, wait: ->(executions) { executions * 2 }, attempts: 10
discard_on DiscardableError
def perform(raising, attempts)