class LogSanity::LogSubscriber::ActiveJob
Public Instance Methods
enqueue(event)
click to toggle source
# File lib/log_sanity/log_subscribers/active_job.rb, line 5 def enqueue(event) info do job = event.payload[:job] e = { 'at' => Time.now, 'event' => 'job_enqueue', 'job' => job.class.name, 'id' => job.job_id, 'queue' => job.queue_name } e['params'] = job.arguments if job.arguments.any? e end end
enqueue_at(event)
click to toggle source
# File lib/log_sanity/log_subscribers/active_job.rb, line 20 def enqueue_at(event) info do job = event.payload[:job] e = { 'at' => Time.now, 'event' => 'job_enqueue', 'job' => job.class.name, 'id' => job.job_id, 'queue' => job.queue_name, 'start_at' => job.scheduled_at } e['params'] = job.arguments if job.arguments.any? e end end
perform(event)
click to toggle source
def perform_start(event)
info do job = event.payload[:job] e = { 'at' => Time.now, 'event' => 'job_start', 'job' => job.class.name, 'id' => job.job_id, 'queue' => job.queue_name, } e['params'] = job.arguments if job.arguments.any? e end
end
# File lib/log_sanity/log_subscribers/active_job.rb, line 51 def perform(event) info do job = event.payload[:job] e = { 'at' => Time.now, 'event' => 'job_perform', 'job' => job.class.name, 'id' => job.job_id, 'queue' => job.queue_name, 'duration' => {'total' => event.duration.round} } e['params'] = job.arguments if job.arguments.any? e end end