method
enqueue
v8.1.1 -
Show latest stable
- Class:
ActiveJob::StructuredEventSubscriber
enqueue(event)public
No documentation available.
# File activejob/lib/active_job/structured_event_subscriber.rb, line 7
def enqueue(event)
job = event.payload[:job]
adapter = event.payload[:adapter]
exception = event.payload[:exception_object] || job.enqueue_error
payload = {
job_class: job.class.name,
job_id: job.job_id,
queue: job.queue_name,
adapter: ActiveJob.adapter_name(adapter),
aborted: event.payload[:aborted],
}
if exception
payload[:exception_class] = exception.class.name
payload[:exception_message] = exception.message
end
if job.class.log_arguments?
payload[:arguments] = job.arguments
end
emit_event("active_job.enqueued", payload)
end