module ActiveJob::TestHelper

def assert_performed_jobs(number, only: nil, except: nil, queue: nil, &block)

end
end
HelloJob.set(queue: :other_queue).perform_later("bogdan")
HelloJob.set(queue: :some_queue).perform_later("jeremy")
assert_performed_jobs 1, queue: :some_queue do
def test_assert_performed_jobs_with_queue_option

then only the job(s) enqueued to a specific queue will be performed.
If the +:queue+ option is specified,

end
end
end
RescueJob.perform_later('david')
LoggingJob.perform_later('stewie')
HelloJob.perform_later('jeremy')
assert_performed_jobs(1, only: ->(job) { job.is_a?(HelloJob) }) do
assert_nothing_raised do
def test_hello_and_logging_jobs

A proc may also be specified. When passed a Proc, the job's instance will be passed as argument.

end
end
end
RescueJob.perform_later('david')
LoggingJob.perform_later('stewie')
HelloJob.perform_later('jeremy')
assert_performed_jobs 2, only: [HelloJob, LoggingJob] do
assert_nothing_raised do
def test_hello_and_logging_jobs

An array may also be specified, to support testing multiple jobs.

end
end
LoggingJob.perform_later
HelloJob.perform_later('jeremy')
assert_performed_jobs 1, except: LoggingJob do
def test_hello_job

then the job(s) except specific class will be performed.
Also if the +:except+ option is specified,

end
end
LoggingJob.perform_later
HelloJob.perform_later('jeremy')
assert_performed_jobs 1, only: HelloJob do
def test_hello_job

then only the listed job(s) will be performed.
This method also supports filtering. If the +:only+ option is specified,

end
end
HelloJob.perform_later('sean')
HelloJob.perform_later('carlos')
assert_performed_jobs 2 do

end
HelloJob.perform_later('robin')
assert_performed_jobs 1 do
def test_jobs_again

jobs to be performed.
If a block is passed, asserts that the block will cause the specified number of

end
assert_performed_jobs 2

perform_enqueued_jobs

HelloJob.perform_later('yves')

assert_performed_jobs 1
end
HelloJob.perform_later('xavier')
perform_enqueued_jobs do

assert_performed_jobs 0
def test_jobs

must be called around or after the job call.
If no block is passed, perform_enqueued_jobs
Asserts that the number of performed jobs matches the given number.
def assert_performed_jobs(number, only: nil, except: nil, queue: nil, &block)
  require_active_job_test_adapter!("assert_performed_jobs")
  if block_given?
    original_count = performed_jobs.size
    perform_enqueued_jobs(only: only, except: except, queue: queue, &block)
    new_count = performed_jobs.size
    performed_jobs_size = new_count - original_count
  else
    performed_jobs_size = performed_jobs_with(only: only, except: except, queue: queue).count
  end
  assert_equal number, performed_jobs_size, "#{number} jobs expected, but #{performed_jobs_size} were performed"
end