DelayedJob log job queue time

queue_time_logger_plugin.rb

# Measures each job's time spent in a queue
#
# Register the pluging to start using it
# Delayed::Worker.plugins << Delayed::QueueTimeLoggerPlugin
#

class Delayed::QueueTimeLoggerPlugin < Delayed::Plugin
  callbacks do |lifecycle|
    lifecycle.before(:perform) do |worker, job|
      queued_for = Time.zone.now - job.created_at
      worker.job_say job,
                     "invoked after queuing for #{queued_for.truncate(1)} s "\
                     "(attempts #{job.attempts})"
    end
  end
end