diff options
| author | bogdanvlviv <bogdanvlviv@gmail.com> | 2018-08-16 19:21:12 +0300 |
|---|---|---|
| committer | bogdanvlviv <bogdanvlviv@gmail.com> | 2018-08-20 13:05:29 +0300 |
| commit | d50fb21e4d7a526de3b0edb9bb5032d4be6175ae (patch) | |
| tree | 9375b4873775117a66166305d04abe5f2d42783a /activejob/lib | |
| parent | e0cf042fa2c499c2e0b8fe95ec02ed79f9178feb (diff) | |
| download | rails-d50fb21e4d7a526de3b0edb9bb5032d4be6175ae.tar.gz rails-d50fb21e4d7a526de3b0edb9bb5032d4be6175ae.tar.bz2 rails-d50fb21e4d7a526de3b0edb9bb5032d4be6175ae.zip | |
Allow `:queue` option to `assert_performed_jobs`.
If the `:queue` option is specified, then only the job(s) enqueued to a specific
queue will be performed.
Example:
```
def test_assert_performed_jobs_with_queue_option
assert_performed_jobs 1, queue: :some_queue do
HelloJob.set(queue: :some_queue).perform_later("jeremy")
HelloJob.set(queue: :other_queue).perform_later("bogdan")
end
end
```
Diffstat (limited to 'activejob/lib')
| -rw-r--r-- | activejob/lib/active_job/test_helper.rb | 14 |
1 files changed, 12 insertions, 2 deletions
diff --git a/activejob/lib/active_job/test_helper.rb b/activejob/lib/active_job/test_helper.rb index 22568c9aa5..3be74e504b 100644 --- a/activejob/lib/active_job/test_helper.rb +++ b/activejob/lib/active_job/test_helper.rb @@ -237,10 +237,20 @@ module ActiveJob # end # end # end - def assert_performed_jobs(number, only: nil, except: nil) + # + # If the +:queue+ option is specified, + # then only the job(s) enqueued to a specific queue will be performed. + # + # def test_assert_performed_jobs_with_queue_option + # assert_performed_jobs 1, queue: :some_queue do + # HelloJob.set(queue: :some_queue).perform_later("jeremy") + # HelloJob.set(queue: :other_queue).perform_later("bogdan") + # end + # end + def assert_performed_jobs(number, only: nil, except: nil, queue: nil) if block_given? original_count = performed_jobs.size - perform_enqueued_jobs(only: only, except: except) { yield } + perform_enqueued_jobs(only: only, except: except, queue: queue) { yield } new_count = performed_jobs.size assert_equal number, new_count - original_count, "#{number} jobs expected, but #{new_count - original_count} were performed" |