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