lib/roqua/probes/monitoring_probe.rb in roqua-support-0.3.0 vs lib/roqua/probes/monitoring_probe.rb in roqua-support-0.3.1
- old
+ new
@@ -1,11 +1,11 @@
require_relative 'base_probe'
module Roqua
module Probes
class MonitoringProbe
- extend BaseProbe
+ include BaseProbe
def incomplete_jobs
Roqua::Scheduling::CronJob.where('completed_at IS NULL OR completed_at < next_run_at')
end
@@ -17,10 +17,10 @@
longest_delay_in_seconds = ([0] + delays).max
(longest_delay_in_seconds / 1.minute).to_i
end
- def call
+ def run
Appsignal.set_gauge('scheduler_delay_in_minutes', longest_delay_in_minutes)
end
end
end
end