class AdeptScaleActiveJob::Base
Public Instance Methods
adept_scale_logger()
click to toggle source
# File lib/adept_scale_active_job.rb, line 5 def adept_scale_logger @@adept_scale_logger ||= Logger.new(STDOUT) end
Private Instance Methods
format_params(job_params)
click to toggle source
@param BasicProcessJob | [@job_id, @queue_name, @priority, @executions, @scheduled_at, @provider_job_id] ie. #<BasicProcessJob:0x00007fd0218ab3a0 @arguments=, @job_id=“4970c4ee-67b7-4cf6-9519-f1bc4513fa4b”, @queue_name=“worker”, @priority=nil, @executions=0, @scheduled_at=1525461719.492488, @provider_job_id=“1da86e157a6cd6dc21791b38”> @param Hash | a key/value hash of our params.
# File lib/adept_scale_active_job.rb, line 42 def format_params job_params #Only allow these params to be stringified params = [:dyno_type, :job_id, :scheduled_at, :total_queue, :running_jobs] params.reduce([]) do |ary, param| ary << "#{param}=#{job_params[param]}" if job_params.has_key?(param) ary end.join(' ') end
log_exception(e)
click to toggle source
Catch all Object level base Exceptions, if we can, so we can remove them from the running process list
# File lib/adept_scale_active_job.rb, line 31 def log_exception e #Don't log the exception to Adept, this is the clients' private business. job_params = {:dyno_type => job.queue_name, :job_id => job.provider_job_id} adept_scale_logger.add(6, "ADEPT_SCALE JOB_FAILED #{format_params job_params}") #reraise so as to hopefully not interefere with other error handling raise e end