ylqjgm
/
canvas-lms
mirror of https://github.com/instructure/canvas-lms.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

partition stats by strand as well as tag 

refs GOOF-543

since some strand:tag isn't necessarily 1:1

Change-Id: I2a149c9b506379dbf2af1ac82f839e2704752af6
Reviewed-on: https://gerrit.instructure.com/162518
Tested-by: Jenkins
Reviewed-by: Josh Orr <jgorr@instructure.com>
Reviewed-by: Rob Orton <rob@instructure.com>
Product-Review: Cody Cutrer <cody@instructure.com>
QA-Review: Cody Cutrer <cody@instructure.com>
This commit is contained in:
Cody Cutrer 2018-08-29 11:08:05 -06:00
parent 932fe01ad8
commit f5cc9f0a3b
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
config/initializers/delayed_job.rb
View File

@ -118,11 +118,13 @@ Delayed::Worker.lifecycle.around(:perform) do |worker, job, &block|
shard_id = job.current_shard.try(:id).to_i
stats = ["delayedjob.queue", "delayedjob.queue.tag.#{obj_tag}.#{method_tag}", "delayedjob.queue.shard.#{shard_id}"]
stats << "delayedjob.queue.jobshard.#{job.shard.id}" if job.respond_to?(:shard)
stats << "delayedjob.queue.strand.#{job.strand}" if job.strand
CanvasStatsd::Statsd.timing(stats, lag)
begin
stats = ["delayedjob.perform", "delayedjob.perform.tag.#{obj_tag}.#{method_tag}", "delayedjob.perform.shard.#{shard_id}"]
stats << "delayedjob.perform.jobshard.#{job.shard.id}" if job.respond_to?(:shard)
stats << "delayedjob.perform.strand.#{job.strand}" if job.strand
CanvasStatsd::Statsd.time(stats) do
block.call(worker, job)
end