Module: Speedshop::Cloudwatch::ActiveJob

Defined in:
lib/speedshop/cloudwatch/active_job.rb

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(base) ⇒ Object 



8
9
10
 
# File 'lib/speedshop/cloudwatch/active_job.rb', line 8

def self.included(base)
  base.around_perform :report_job_metrics
end

Instance Method Details

#report_job_metrics ⇒ Object 



12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/speedshop/cloudwatch/active_job.rb', line 12

def report_job_metrics
  begin
    observation = Observations::ActiveJob.queue_latency(self)
    if observation
      MetricMapper.instance.report(
        metric: :QueueLatency,
        value: observation[:value],
        dimensions: observation[:dimensions],
        integration: :active_job
      )
    end
  rescue => e
    Speedshop::Cloudwatch.log_error("Failed to collect ActiveJob metrics: #{e.message}", e)
  end
  yield
end