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