Revert "FIX: Don't try to dequeue an empty queue."

This reverts commit 1af7d4a894ad809de6424d043600e32e7c01bda9.
This commit is contained in:
Guo Xiang Tan 2018-06-19 15:49:45 +08:00
parent 41c1e1b302
commit df24c51c6f

View File

@ -62,7 +62,6 @@ module Scheduler
# using non_block to match Ruby #deq
def do_work(non_block = false)
return unless @queue.size > 0
db, job, desc = @queue.deq(non_block)
db ||= RailsMultisite::ConnectionManagement::DEFAULT