Module: Sidekiq::Job

Defined in:
lib/sidekiq/testing.rb

Defined Under Namespace

Modules: ClassMethods

Class Method Summary collapse

Class Method Details

.clear_all ⇒ Object

Clear all queued jobs



311
312
313
 
# File 'lib/sidekiq/testing.rb', line 311

def clear_all
  Queues.clear_all
end

.drain_all ⇒ Object

Drain (execute) all queued jobs



316
317
318
319
320
321
322
323
324
 
# File 'lib/sidekiq/testing.rb', line 316

def drain_all
  while jobs.any?
    job_classes = jobs.map { |job| job["class"] }.uniq

    job_classes.each do |job_class|
      Sidekiq::Testing.constantize(job_class).drain
    end
  end
end

.jobs ⇒ Object

:nodoc:



306
307
308
 
# File 'lib/sidekiq/testing.rb', line 306

def jobs # :nodoc:
  Queues.jobs_by_queue.values.flatten
end