lib/sidekiq/testing.rb in sidekiq-7.2.0 vs lib/sidekiq/testing.rb in sidekiq-7.2.1
- old
+ new
@@ -276,10 +276,10 @@
# Pop out a single job and perform it
def perform_one
raise(EmptyQueueError, "perform_one called with empty job queue") if jobs.empty?
next_job = jobs.first
- Queues.delete_for(next_job["jid"], queue, to_s)
+ Queues.delete_for(next_job["jid"], next_job["queue"], to_s)
process_job(next_job)
end
def process_job(job)
inst = new