module ActiveJob::TestHelper
def assert_performed_jobs(number, only: nil, except: nil, queue: nil, &block)
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