class Hickory::LogSubscribers::ActiveJob
Public Instance Methods
enqueue(event)
click to toggle source
# File lib/hickory/log_subscribers/active_job.rb, line 4 def enqueue(event) logger.info('job-enqueued', job_metadata(event)) end
enqueue_retry(event)
click to toggle source
# File lib/hickory/log_subscribers/active_job.rb, line 8 def enqueue_retry(event) metadata = job_metadata(event) metadata.merge!({ error: event.payload[:error], wait: event.payload[:wait] }) logger.info('job-retry-enqueued', metadata) end
perform(event)
click to toggle source
# File lib/hickory/log_subscribers/active_job.rb, line 22 def perform(event) logger.info('job-perform', job_metadata(event)) end
perform_start(event)
click to toggle source
# File lib/hickory/log_subscribers/active_job.rb, line 18 def perform_start(event) logger.info('job-perform-start', job_metadata(event)) end
retry_discard(event)
click to toggle source
# File lib/hickory/log_subscribers/active_job.rb, line 35 def retry_discard(event) metadata = job_metadata(event) metadata.merge!({ error: event.payload[:error] }) logger.info('job-discard', metadata) end
retry_stopped(event)
click to toggle source
# File lib/hickory/log_subscribers/active_job.rb, line 26 def retry_stopped(event) metadata = job_metadata(event) metadata.merge!({ error: event.payload[:error] }) logger.info('job-retry-stopped', metadata) end
Private Instance Methods
job_metadata(event)
click to toggle source
# File lib/hickory/log_subscribers/active_job.rb, line 46 def job_metadata(event) job = event.payload[:job] { job_id: job.job_id, queue: job.queue_name, priority: job.priority, executions: job.executions } end