mirror of
https://github.com/rails/rails.git
synced 2022-11-09 12:12:34 -05:00
77 lines
2.5 KiB
Ruby
77 lines
2.5 KiB
Ruby
require 'active_job/arguments'
|
|
|
|
module ActiveJob
|
|
module Enqueuing
|
|
extend ActiveSupport::Concern
|
|
|
|
# Includes the +perform_later+ method for job initialization.
|
|
module ClassMethods
|
|
# Push a job onto the queue. The arguments must be legal JSON types
|
|
# (string, int, float, nil, true, false, hash or array) or
|
|
# GlobalID::Identification instances. Arbitrary Ruby objects
|
|
# are not supported.
|
|
#
|
|
# Returns an instance of the job class queued with arguments available in
|
|
# Job#arguments.
|
|
def perform_later(*args)
|
|
job_or_instantiate(*args).enqueue
|
|
end
|
|
|
|
protected
|
|
def job_or_instantiate(*args)
|
|
args.first.is_a?(self) ? args.first : new(*args)
|
|
end
|
|
end
|
|
|
|
# Reschedules the job to be re-executed. This is useful in combination
|
|
# with the +rescue_from+ option. When you rescue an exception from your job
|
|
# you can ask Active Job to retry performing your job.
|
|
#
|
|
# ==== Options
|
|
# * <tt>:wait</tt> - Enqueues the job with the specified delay
|
|
# * <tt>:wait_until</tt> - Enqueues the job at the time specified
|
|
# * <tt>:queue</tt> - Enqueues the job on the specified queue
|
|
#
|
|
# ==== Examples
|
|
#
|
|
# class SiteScrapperJob < ActiveJob::Base
|
|
# rescue_from(ErrorLoadingSite) do
|
|
# retry_job queue: :low_priority
|
|
# end
|
|
#
|
|
# def perform(*args)
|
|
# # raise ErrorLoadingSite if cannot scrape
|
|
# end
|
|
# end
|
|
def retry_job(options={})
|
|
enqueue options
|
|
end
|
|
|
|
# Enqueues the job to be performed by the queue adapter.
|
|
#
|
|
# ==== Options
|
|
# * <tt>:wait</tt> - Enqueues the job with the specified delay
|
|
# * <tt>:wait_until</tt> - Enqueues the job at the time specified
|
|
# * <tt>:queue</tt> - Enqueues the job on the specified queue
|
|
#
|
|
# ==== Examples
|
|
#
|
|
# my_job_instance.enqueue
|
|
# my_job_instance.enqueue wait: 5.minutes
|
|
# my_job_instance.enqueue queue: :important
|
|
# my_job_instance.enqueue wait_until: Date.tomorrow.midnight
|
|
def enqueue(options={})
|
|
self.scheduled_at = options[:wait].seconds.from_now.to_f if options[:wait]
|
|
self.scheduled_at = options[:wait_until].to_f if options[:wait_until]
|
|
self.queue_name = self.class.queue_name_from_part(options[:queue]) if options[:queue]
|
|
run_callbacks :enqueue do
|
|
if self.scheduled_at
|
|
self.class.queue_adapter.enqueue_at self, self.scheduled_at
|
|
else
|
|
self.class.queue_adapter.enqueue self
|
|
end
|
|
end
|
|
self
|
|
end
|
|
end
|
|
end
|