diff --git a/lib/delayed/monitor.rb b/lib/delayed/monitor.rb index b583c9e..1293b8d 100644 --- a/lib/delayed/monitor.rb +++ b/lib/delayed/monitor.rb @@ -36,7 +36,7 @@ def run! attr_reader :jobs def emit_metric!(metric) - send("#{metric}_grouped").reverse_merge(default_results).each do |(priority, queue), value| + send(:"#{metric}_grouped").reverse_merge(default_results).each do |(priority, queue), value| ActiveSupport::Notifications.instrument( "delayed.job.#{metric}", default_tags.merge(priority: Priority.new(priority).to_s, queue: queue, value: value),