lib/sidekiq/instrument/middleware/server.rb in sidekiq-instrument-0.6.1 vs lib/sidekiq/instrument/middleware/server.rb in sidekiq-instrument-0.6.2
- old
+ new
@@ -5,24 +5,24 @@
module Sidekiq::Instrument
class ServerMiddleware
include Sidekiq::Instrument::MetricNames
- def call(worker, job, queue, &block)
+ def call(worker, _job, _queue, &block)
Statter.statsd.increment(metric_name(worker, 'dequeue'))
Statter.dogstatsd&.increment('sidekiq.dequeue', worker_dog_options(worker))
start_time = Time.now
- WorkerMetrics.trace_workers_decrement_counter(worker.class.to_s.underscore)
yield block
execution_time_ms = (Time.now - start_time) * 1000
Statter.statsd.measure(metric_name(worker, 'runtime'), execution_time_ms)
Statter.dogstatsd&.timing('sidekiq.runtime', execution_time_ms, worker_dog_options(worker))
rescue StandardError => e
Statter.statsd.increment(metric_name(worker, 'error'))
Statter.dogstatsd&.increment('sidekiq.error', worker_dog_options(worker))
raise e
ensure
+ WorkerMetrics.trace_workers_decrement_counter(worker.class.to_s.underscore)
Statter.dogstatsd&.flush(sync: true)
end
end
end