Contents

require 'test_helper'

class ActiveJob::RetriableTest < ActiveJob::TestCase
  test 'failed job is retried until DEFAULT_MAX' do
    assert_performed_jobs 25 do
      RaiseJob.perform_later
    end
  end

  test 'failed job is retried until specified max_retry' do
    assert_performed_jobs 10 do
      MaxJob.perform_later
    end
  end

  test 'failed job with custom rescue_from is retried' do
    assert_performed_jobs 3 do
      RescueJob.perform_later
    end
  end

  test 'failed job with custom rescue_from uses custom retry wait time' do
    perform_enqueued_jobs do
      RescueJob.perform_later
    end

    # Two jobs are performed with +at+ keys
    assert_equal 2, performed_jobs.map { |job| job[:at] }.compact.size
  end

  test 'invokes all callbacks' do
    CallbacksJob.reset_results!

    perform_enqueued_jobs do
      CallbacksJob.perform_later
    end

    assert_equal 3, CallbacksJob.callback_results.size
  end

  test 'sets current_exception and is available in callbacks' do
    CallbacksJob.reset_results!

    perform_enqueued_jobs do
      CallbacksJob.perform_later
    end

    assert CallbacksJob.callback_results.map { |ex| StandardError === ex }.all?
  end

  test 'raises exception when include in an ActiveJob with an adapter that does not support an enqueue_at method' do
    assert_raises RuntimeError do
      Class.new(ActiveJob::Base) do
        # Set to an adapter known to not support scheduled jobs (no :enqueue_at support)
        self.queue_adapter = :inline

        include ActiveJob::Retriable
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
activejob-retriable-5.0.1	test/active_job/retriable_test.rb
activejob-retriable-5.0.0	test/active_job/retriable_test.rb