34 lines
1.2 KiB
Ruby
34 lines
1.2 KiB
Ruby
module ResqueJobLogging
|
|
def around_perform_log_job(*args)
|
|
Rails.logger.auto_flushing=1
|
|
log_string = "event=resque_job job=#{self} "
|
|
error = nil
|
|
time = Benchmark.realtime{
|
|
begin
|
|
yield
|
|
rescue Exception => e
|
|
error = e
|
|
end
|
|
}*1000
|
|
if error
|
|
log_string += "status=error "
|
|
log_string << "error_class=#{error.class} error_message='#{error.message}' "
|
|
log_string << "orig_error_message='#{error.original_error.message}'" if error.respond_to?(:original_error)
|
|
log_string << "annotated_source='#{error.annoted_source_code.to_s}' " if error.respond_to?(:annoted_source_code)
|
|
log_string << "app_backtrace='#{application_trace(error).join(";")}' "
|
|
else
|
|
log_string += "status=complete "
|
|
end
|
|
log_string += "ms=#{time} "
|
|
args.each_with_index{|arg,idx| log_string += "arg#{idx.succ}=\"#{arg.to_s[0..30]}\" "}
|
|
|
|
Rails.logger.info(log_string)
|
|
raise error if error
|
|
end
|
|
|
|
def application_trace(error) #copied from ActionDispatch::ShowExceptions
|
|
defined?(Rails) && Rails.respond_to?(:backtrace_cleaner) ?
|
|
Rails.backtrace_cleaner.clean(error.backtrace, :silent) :
|
|
error.backtrace
|
|
end
|
|
end
|