class Dronejob::Modules::Log::ActiveJob::Logging::LogSubscriber

Public Instance Methods

enqueue(event) click to toggle source
# File lib/dronejob/modules/log.rb, line 124
def enqueue(event)
  info do
    job = event.payload[:job]
    log_object("queueing #{job.class.name}", job)
  end
end
enqueue_at(event) click to toggle source
# File lib/dronejob/modules/log.rb, line 131
def enqueue_at(event)
  info do
    job = event.payload[:job]
    log_object("scheduling #{job.class.name}", job)
  end
end
log_object(message, job) click to toggle source
# File lib/dronejob/modules/log.rb, line 152
def log_object(message, job)
  if job.option(:dronejob_log) == "google"
    { message: "[#{job.job_id}] #{message}", job_id: job.job_id, queue: job.queue_name, phase: job.phase }
  else
    message
  end
end
perform(event) click to toggle source
# File lib/dronejob/modules/log.rb, line 145
def perform(event)
  info do
    job = event.payload[:job]
    log_object("finishing #{job.class.name}", job)
  end
end
perform_start(event) click to toggle source
# File lib/dronejob/modules/log.rb, line 138
def perform_start(event)
  info do
    job = event.payload[:job]
    log_object("starting #{job.class.name}", job)
  end
end