Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
G
gitlab-ce
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
1
Merge Requests
1
Analytics
Analytics
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Commits
Issue Boards
Open sidebar
nexedi
gitlab-ce
Commits
46992424
Commit
46992424
authored
Nov 05, 2019
by
Dylan Griffith
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Revert "Merge branch 'include-worker-attributes-in-sidekiq-metrics' into 'master'"
This reverts merge request !19491
parent
08d34252
Changes
3
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
39 additions
and
80 deletions
+39
-80
changelogs/unreleased/include-worker-attributes-in-sidekiq-metrics.yml
...released/include-worker-attributes-in-sidekiq-metrics.yml
+0
-5
lib/gitlab/sidekiq_middleware/metrics.rb
lib/gitlab/sidekiq_middleware/metrics.rb
+6
-16
spec/lib/gitlab/sidekiq_middleware/metrics_spec.rb
spec/lib/gitlab/sidekiq_middleware/metrics_spec.rb
+33
-59
No files found.
changelogs/unreleased/include-worker-attributes-in-sidekiq-metrics.yml
deleted
100644 → 0
View file @
08d34252
---
title
:
Add worker attributes to Sidekiq metrics
merge_request
:
19491
author
:
type
:
other
lib/gitlab/sidekiq_middleware/metrics.rb
View file @
46992424
...
...
@@ -13,8 +13,8 @@ module Gitlab
@metrics
[
:sidekiq_concurrency
].
set
({},
Sidekiq
.
options
[
:concurrency
].
to_i
)
end
def
call
(
worker
,
job
,
queue
)
labels
=
create_labels
(
worker
,
queue
)
def
call
(
_
worker
,
job
,
queue
)
labels
=
create_labels
(
queue
)
queue_duration
=
::
Gitlab
::
InstrumentationHelper
.
queue_duration_for_job
(
job
)
@metrics
[
:sidekiq_jobs_queue_duration_seconds
].
observe
(
labels
,
queue_duration
)
if
queue_duration
...
...
@@ -62,20 +62,10 @@ module Gitlab
}
end
def
create_labels
(
worker
,
queue
)
labels
=
{
queue:
queue
}
return
labels
unless
worker
.
include?
WorkerAttributes
labels
[
:latency_sensitive
]
=
true
if
worker
.
latency_sensitive_worker?
labels
[
:external_deps
]
=
true
if
worker
.
worker_has_external_dependencies?
feature_category
=
worker
.
get_feature_category
labels
[
:feat_cat
]
=
feature_category
if
feature_category
resource_boundary
=
worker
.
get_worker_resource_boundary
labels
[
:boundary
]
=
resource_boundary
if
resource_boundary
&&
resource_boundary
!=
:unknown
labels
def
create_labels
(
queue
)
{
queue:
queue
}
end
def
get_thread_cputime
...
...
spec/lib/gitlab/sidekiq_middleware/metrics_spec.rb
View file @
46992424
# frozen_string_literal: true
require
'fast_spec_helper'
require
'rspec-parameterized'
describe
Gitlab
::
SidekiqMiddleware
::
Metrics
do
using
RSpec
::
Parameterized
::
TableSyntax
let
(
:middleware
)
{
described_class
.
new
}
let
(
:concurrency_metric
)
{
double
(
'concurrency metric'
)
}
...
...
@@ -48,7 +45,7 @@ describe Gitlab::SidekiqMiddleware::Metrics do
let
(
:job
)
{
{}
}
let
(
:job_status
)
{
:done
}
let
(
:labels
)
{
{
queue: :test
}
}
let
(
:labels_with_job_status
)
{
labels
.
merge
(
job_status:
job_status
)
}
let
(
:labels_with_job_status
)
{
{
queue: :test
,
job_status:
job_status
}
}
let
(
:thread_cputime_before
)
{
1
}
let
(
:thread_cputime_after
)
{
2
}
...
...
@@ -60,31 +57,11 @@ describe Gitlab::SidekiqMiddleware::Metrics do
let
(
:queue_duration_for_job
)
{
0.01
}
where
(
:worker_has_attributes
,
:worker_is_latency_sensitive
,
:worker_has_external_dependencies
,
:worker_feature_category
,
:worker_resource_boundary
,
:labels
)
do
false
|
false
|
false
|
nil
|
nil
|
{
queue: :test
}
true
|
false
|
false
|
nil
|
nil
|
{
queue: :test
}
true
|
true
|
false
|
nil
|
nil
|
{
queue: :test
,
latency_sensitive:
true
}
true
|
false
|
true
|
nil
|
nil
|
{
queue: :test
,
external_deps:
true
}
true
|
false
|
false
|
:authentication
|
nil
|
{
queue: :test
,
feat_cat: :authentication
}
true
|
false
|
false
|
nil
|
:cpu
|
{
queue: :test
,
boundary: :cpu
}
true
|
false
|
false
|
nil
|
:memory
|
{
queue: :test
,
boundary: :memory
}
true
|
false
|
false
|
nil
|
:unknown
|
{
queue: :test
}
true
|
true
|
true
|
:authentication
|
:cpu
|
{
queue: :test
,
latency_sensitive:
true
,
external_deps:
true
,
feat_cat: :authentication
,
boundary: :cpu
}
end
with_them
do
before
do
allow
(
middleware
).
to
receive
(
:get_thread_cputime
).
and_return
(
thread_cputime_before
,
thread_cputime_after
)
allow
(
Gitlab
::
Metrics
::
System
).
to
receive
(
:monotonic_time
).
and_return
(
monotonic_time_before
,
monotonic_time_after
)
allow
(
Gitlab
::
InstrumentationHelper
).
to
receive
(
:queue_duration_for_job
).
with
(
job
).
and_return
(
queue_duration_for_job
)
# Attributes
allow
(
worker
).
to
receive
(
:include?
).
with
(
WorkerAttributes
).
and_return
(
worker_has_attributes
)
allow
(
worker
).
to
receive
(
:latency_sensitive_worker?
).
and_return
(
worker_is_latency_sensitive
)
allow
(
worker
).
to
receive
(
:worker_has_external_dependencies?
).
and_return
(
worker_has_external_dependencies
)
allow
(
worker
).
to
receive
(
:get_worker_resource_boundary
).
and_return
(
worker_resource_boundary
)
allow
(
worker
).
to
receive
(
:get_feature_category
).
and_return
(
worker_feature_category
)
expect
(
running_jobs_metric
).
to
receive
(
:increment
).
with
(
labels
,
1
)
expect
(
running_jobs_metric
).
to
receive
(
:increment
).
with
(
labels
,
-
1
)
...
...
@@ -105,8 +82,6 @@ describe Gitlab::SidekiqMiddleware::Metrics do
let
(
:queue_duration_for_job
)
{
nil
}
it
'does not set the queue_duration_seconds histogram'
do
expect
(
queue_duration_seconds
).
not_to
receive
(
:observe
)
middleware
.
call
(
worker
,
job
,
:test
)
{
nil
}
end
end
...
...
@@ -131,5 +106,4 @@ describe Gitlab::SidekiqMiddleware::Metrics do
end
end
end
end
end
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment