Sha256: d64738e735a63c603d753d8022b1a6d108a666342be5f26ca37de09c4e041f5b
Contents?: true
Size: 1.89 KB
Versions: 4
Compression:
Stored size: 1.89 KB
Contents
# encoding: UTF-8
require 'active_support/concern'
module RocketJob
module Plugins
# Automatically starts a new instance of this job anytime it fails, aborts, or completes.
# Failed jobs are aborted so that they cannot be restarted.
# On destroy this job is destroyed without starting a new copy. Abort the job first to get
# it to start a new instance before destroying.
# Include RocketJob::Plugins::Singleton to prevent multiple copies of a job from running at
# the same time.
#
# Note:
# - The job will not be restarted if:
# - A validation fails after cloning this job.
# - The job has expired.
module Restart
extend ActiveSupport::Concern
# Attributes to exclude when copying across the attributes to the new instance
RESTART_EXCLUDES = %w(_id state created_at started_at completed_at failure_count worker_name percent_complete exception result run_at)
included do
after_abort :rocket_job_restart_new_instance
after_complete :rocket_job_restart_new_instance
after_fail :rocket_job_restart_abort
end
private
# Run again in the future, even if this run fails with an exception
def rocket_job_restart_new_instance
return if expired?
attrs = attributes.dup
RESTART_EXCLUDES.each { |attr| attrs.delete(attr) }
# Copy across run_at for future dated jobs
attrs['run_at'] = run_at if run_at && (run_at > Time.now)
# Allow Singleton to prevent the creation of a new job if one is already running
job = self.class.create(attrs)
if job.persisted?
logger.info("Started a new job instance: #{job.id}")
else
logger.info('New job instance not started since one is already active')
end
end
def rocket_job_restart_abort
new_record? ? abort : abort!
end
end
end
end
Version data entries
4 entries across 4 versions & 1 rubygems