mirror of
https://github.com/mperham/sidekiq.git
synced 2022-11-09 13:52:34 -05:00
Unique all workers and ensure symbol queues are stringified via testing
API
This commit is contained in:
parent
901bbc715b
commit
df755bbeef
2 changed files with 2 additions and 2 deletions
|
@ -261,7 +261,7 @@ module Sidekiq
|
|||
# Drain all queued jobs across all workers
|
||||
def drain_all
|
||||
while jobs.any?
|
||||
worker_classes = jobs.map { |job| job["class"] }
|
||||
worker_classes = jobs.map { |job| job["class"] }.uniq
|
||||
|
||||
worker_classes.each do |worker_class|
|
||||
worker_class.constantize.drain
|
||||
|
|
|
@ -286,7 +286,7 @@ class TestTesting < Sidekiq::Test
|
|||
|
||||
class AltQueueWorker
|
||||
include Sidekiq::Worker
|
||||
sidekiq_options queue: "alt"
|
||||
sidekiq_options queue: :alt
|
||||
def perform(a, b)
|
||||
a + b
|
||||
end
|
||||
|
|
Loading…
Add table
Reference in a new issue