Module: Sidekiq::Worker::ClassMethods
- Defined in:
- lib/sidekiq/testing.rb,
lib/sidekiq/worker.rb
Overview
The Sidekiq testing infrastructure overrides perform_async so that it does not actually touch the network. Instead it stores the asynchronous jobs in a per-class array so that their presence/absence can be asserted by your tests.
This is similar to ActionMailer’s :test delivery_method and its ActionMailer::Base.deliveries array.
Example:
require 'sidekiq/testing'
assert_equal 0, HardWorker.jobs.size
HardWorker.perform_async(:something)
assert_equal 1, HardWorker.jobs.size
assert_equal :something, HardWorker.jobs[0]['args'][0]
assert_equal 0, Sidekiq::Extensions::DelayedMailer.jobs.size
MyMailer.delay.send_welcome_email('[email protected]')
assert_equal 1, Sidekiq::Extensions::DelayedMailer.jobs.size
You can also clear and drain all workers’ jobs:
assert_equal 0, Sidekiq::Extensions::DelayedMailer.jobs.size
assert_equal 0, Sidekiq::Extensions::DelayedModel.jobs.size
MyMailer.delay.send_welcome_email('[email protected]')
MyModel.delay.do_something_hard
assert_equal 1, Sidekiq::Extensions::DelayedMailer.jobs.size
assert_equal 1, Sidekiq::Extensions::DelayedModel.jobs.size
Sidekiq::Worker.clear_all # or .drain_all
assert_equal 0, Sidekiq::Extensions::DelayedMailer.jobs.size
assert_equal 0, Sidekiq::Extensions::DelayedModel.jobs.size
This can be useful to make sure jobs don’t linger between tests:
RSpec.configure do |config|
config.before(:each) do
Sidekiq::Worker.clear_all
end
end
or for acceptance testing, i.e. with cucumber:
AfterStep do
Sidekiq::Worker.drain_all
end
When I sign up as "[email protected]"
Then I should receive a welcome email to "[email protected]"
Constant Summary collapse
- DEFAULT_OPTIONS =
{ 'retry' => true, 'queue' => 'default' }
Instance Method Summary collapse
-
#clear ⇒ Object
Clear all jobs for this worker.
-
#client_push(item) ⇒ Object
:nodoc:.
-
#drain ⇒ Object
Drain and run all jobs for this worker.
-
#get_sidekiq_options ⇒ Object
:nodoc:.
-
#jobs ⇒ Object
Jobs queued for this worker.
- #perform_async(*args) ⇒ Object
- #perform_in(interval, *args) ⇒ Object (also: #perform_at)
-
#sidekiq_options(opts = {}) ⇒ Object
Allows customization for this type of Worker.
Instance Method Details
#clear ⇒ Object
Clear all jobs for this worker
80 81 82 |
# File 'lib/sidekiq/testing.rb', line 80 def clear jobs.clear end |
#client_push(item) ⇒ Object
:nodoc:
67 68 69 |
# File 'lib/sidekiq/worker.rb', line 67 def client_push(item) # :nodoc: Sidekiq::Client.push(item.stringify_keys) end |
#drain ⇒ Object
Drain and run all jobs for this worker
85 86 87 88 89 |
# File 'lib/sidekiq/testing.rb', line 85 def drain while job = jobs.shift do new.perform(*job['args']) end end |
#get_sidekiq_options ⇒ Object
:nodoc:
63 64 65 |
# File 'lib/sidekiq/worker.rb', line 63 def # :nodoc: self. ||= DEFAULT_OPTIONS end |
#jobs ⇒ Object
Jobs queued for this worker
75 76 77 |
# File 'lib/sidekiq/testing.rb', line 75 def jobs Worker.jobs[self] end |
#perform_async(*args) ⇒ Object
37 38 39 |
# File 'lib/sidekiq/worker.rb', line 37 def perform_async(*args) client_push('class' => self, 'args' => args) end |
#perform_in(interval, *args) ⇒ Object Also known as: perform_at
41 42 43 44 45 |
# File 'lib/sidekiq/worker.rb', line 41 def perform_in(interval, *args) int = interval.to_f ts = (int < 1_000_000_000 ? Time.now.to_f + int : int) client_push('class' => self, 'args' => args, 'at' => ts) end |
#sidekiq_options(opts = {}) ⇒ Object
Allows customization for this type of Worker. Legal options:
:queue - use a named queue for this Worker, default 'default'
:retry - enable the RetryJobs middleware for this Worker, default *true*
:backtrace - whether to save any error backtrace in the retry payload to display in web UI,
can be true, false or an integer number of lines to save, default *false*
56 57 58 59 |
# File 'lib/sidekiq/worker.rb', line 56 def (opts={}) self. = .merge((opts || {}).stringify_keys) ::Sidekiq.logger.warn("#{self.name} - :timeout is unsafe and support has been removed from Sidekiq, see http://bit.ly/OtYpK for details") end |