aboutsummaryrefslogtreecommitdiffstats
path: root/lib/active_job/log_subscriber.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/active_job/log_subscriber.rb')
-rw-r--r--lib/active_job/log_subscriber.rb11
1 files changed, 10 insertions, 1 deletions
diff --git a/lib/active_job/log_subscriber.rb b/lib/active_job/log_subscriber.rb
index 472c9f3081..eae6c30745 100644
--- a/lib/active_job/log_subscriber.rb
+++ b/lib/active_job/log_subscriber.rb
@@ -4,12 +4,21 @@ module ActiveJob
class LogSubscriber < ActiveSupport::LogSubscriber
def enqueue(event)
queue_name = event.payload[:adapter].name.demodulize.remove('Adapter')
- job_name = event.payload[:job].name
+ job_name = event.payload[:job].name
args = event.payload[:args].any? ? ": #{event.payload[:args].inspect}" : ""
info "Enqueued #{job_name} to #{queue_name}" + args
end
+ def enqueue_at(event)
+ queue_name = event.payload[:adapter].name.demodulize.remove('Adapter')
+ job_name = event.payload[:job].name
+ args = event.payload[:args].any? ? ": #{event.payload[:args].inspect}" : ""
+ time = event.payload[:timestamp]
+
+ info "Enqueued #{job_name} to #{queue_name} at #{time}" + args
+ end
+
def logger
ActiveJob::Base.logger
end