module SidekiqScheduler::Utils
def self.new_rufus_scheduler(options = {})
-
(Rufus::Scheduler)
- the scheduler instance
def self.new_rufus_scheduler(options = {}) Rufus::Scheduler.new(options).tap do |scheduler| scheduler.define_singleton_method(:on_post_trigger) do |job, triggered_time| SidekiqScheduler::Utils.update_job_last_time(job.tags[0], triggered_time) SidekiqScheduler::Utils.update_job_next_time(job.tags[0], job.next_time) end end end