FEATURE: raise an event when a sidekiq job runs

2017-10-23 17:30:17 +11:00 · 2017-10-23 17:30:17 +11:00 · 361fbfa518
parent 55d096ee8b
commit 361fbfa518
1 changed files with 5 additions and 1 deletions
--- a/lib/sidekiq/pausable.rb
+++ b/lib/sidekiq/pausable.rb
@ -76,7 +76,11 @@ class Sidekiq::Pausable
    if Sidekiq.paused?
      worker.class.perform_in(@delay, *msg['args'])
    else
-      yield
+      start = Process.clock_gettime(Process::CLOCK_MONOTONIC)
+      result = yield
+      duration = Process.clock_gettime(Process::CLOCK_MONOTONIC) - start
+      DiscourseEvent.trigger(:sidekiq_job_ran, worker, msg, queue, duration)
+      result
    end
  end