module SidekiqScheduler::Client
def remove_scheduler_queue(timestamp)
def remove_scheduler_queue(timestamp) key = "delayed:#{timestamp}" if 0 == Sidekiq.redis { |r| r.llen(key) } Sidekiq.redis { |r| r.del(key) } Sidekiq.redis { |r| r.zrem('delayed_queue_schedule', timestamp) } end end