class Workerholic::JobProcessor

Attributes

serialized_job[R]

Public Class Methods

new(serialized_job) click to toggle source
# File lib/workerholic/job_processor.rb, line 5
def initialize(serialized_job)
  @serialized_job = serialized_job
  @logger = LogManager.new
end

Public Instance Methods

process() click to toggle source
# File lib/workerholic/job_processor.rb, line 10
def process
  job = JobSerializer.deserialize(serialized_job)

  job.statistics.started_at = Time.now.to_f
  job_result = job.perform
  job.statistics.completed_at = Time.now.to_f

  StatsStorage.save_job('completed_jobs', job)
  StatsStorage.update_historical_stats('completed_jobs', job.klass.to_s)

  # @logger.info("Completed: your job from class #{job.klass} was completed on #{job.statistics.completed_at}.")

  # forces AR to release idle connections back to the pool
  ActiveRecord::Base.clear_active_connections! if defined?(Rails)

  job_result
rescue Exception => e
  job.statistics.errors.push([e.class, e.message])
  retry_job(job, e)
end

Private Instance Methods

retry_job(job, error) click to toggle source
# File lib/workerholic/job_processor.rb, line 33
def retry_job(job, error)
  if JobRetry.new(job: job).retry
    @logger.error("Failed: your job from class #{job.klass} was unsuccessful because of the folloing error: #{error} => #{error.message}. Retrying in 10 secs...")
  else
    job.statistics.failed_on = Time.now.to_f
    StatsStorage.save_job('failed_jobs', job)
    StatsStorage.update_historical_stats('failed_jobs', job.klass.name)

    @logger.error("Failed: your job from class #{job.class} was unsuccessful.")
  end
end