module SidekiqScheduler::RedisManager
def self.remove_elder_job_instances(job_name)
-
job_name
(String
) -- The name of the job
def self.remove_elder_job_instances(job_name) seconds_ago = Time.now.to_i - REGISTERED_JOBS_THRESHOLD_IN_SECONDS Sidekiq.redis do |r| r.zremrangebyscore(pushed_job_key(job_name), 0, seconds_ago) end end