Skip to content

Instantly share code, notes, and snippets.

@kares
Created June 14, 2011 11:31
Show Gist options
  • Save kares/1024726 to your computer and use it in GitHub Desktop.
Save kares/1024726 to your computer and use it in GitHub Desktop.
Recurring Job using Delayed::Job
#
# Recurring Job using Delayed::Job
#
# Setup Your job the "plain-old" DJ (perform) way, include this module
# and Your handler will re-schedule itself every time it succeeds.
#
# Sample :
#
# class MyJob
# include Delayed::ScheduledJob
#
# run_every 1.day
#
# def display_name
# "MyJob"
# end
#
# def perform
# # code to run ...
# end
#
# end
#
# inspired by http://rifkifauzi.wordpress.com/2010/07/29/8/
#
module Delayed
module ScheduledJob
def self.included(base)
base.extend(ClassMethods)
base.class_eval do
@@logger = Delayed::Worker.logger
cattr_reader :logger
end
end
def perform_with_schedule
perform_without_schedule
schedule! # only schedule if job did not raise
end
# schedule this "repeating" job
def schedule!(run_at = nil)
run_at ||= self.class.run_at
Delayed::Job.enqueue self, 0, run_at.utc
end
# re-schedule this job instance
def reschedule!
schedule! Time.now
end
module ClassMethods
def method_added(name)
if name.to_sym == :perform &&
! instance_methods(false).map(&:to_sym).include?(:perform_without_schedule)
alias_method_chain :perform, :schedule
end
end
def run_at
run_interval.from_now
end
def run_interval
@run_interval ||= 1.hour
end
def run_every(time)
@run_interval = time
end
#
def schedule(run_at = nil)
schedule!(run_at) unless scheduled?
end
def schedule!(run_at = nil)
new.schedule!(run_at)
end
def scheduled?
Delayed::Job.where("handler LIKE ?", "%#{name}%").count > 0
end
end
end
end
@dcuddeback
Copy link

This causes a stack overflow in Ruby 1.9, because instance_methods returns a list of symbols instead of a list of strings. To be compatible with all versions of Ruby, you need to add .map(&:to_s) after instance_methods(false).

@kares
Copy link
Author

kares commented Jan 27, 2012

you're right - updated, thanks

@dcuddeback
Copy link

No problem

@afn
Copy link

afn commented Jul 1, 2014

A more extensive version of this is available as a gem. I'd love to hear your feedback on it: https://github.com/amitree/delayed_job_recurring.

@snackycracky
Copy link

yeah its nice but I think https://github.com/tomykaira/clockwork should be used for that

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment