class SidekiqScheduler::Manager
def clear_scheduled_work
def clear_scheduled_work redis do |conn| queues = conn.zrange('delayed_queue_schedule', 0, -1).to_a conn.del(*queues.map { |t| "delayed:#{t}" }) unless queues.empty? conn.del('delayed_queue_schedule') end end