lib/sidekiq/testing.rb in sidekiq-4.2.1 vs lib/sidekiq/testing.rb in sidekiq-4.2.2

@@ -262,10 +262,10 @@
 
       # Drain and run all jobs for this worker
       def drain
         while jobs.any?
           next_job = jobs.first
-          Queues.delete_for(next_job["jid"], queue, self.to_s)
+          Queues.delete_for(next_job["jid"], next_job["queue"], self.to_s)
           process_job(next_job)
         end
       end
 
       # Pop out a single job and perform it