module SidekiqScheduler::RedisManager

def self.remove_elder_job_instances(job_name)

Parameters:
  • 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