Add `drain_worker_queues` helper method.
 
This is commonly needed in tests, as a means
to drain all jobs processed by a particular
worker.