8000 Fix namespace and subsystem in multiprocess mode (#159) · shadow4125/client_python@ce7f297 · GitHub
[go: up one dir, main page]

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Appearance settings

Commit ce7f297

Browse files
atollenabrian-brazil
authored andcommitted
Fix namespace and subsystem in multiprocess mode (prometheus#159)
See prometheus#158 for details.
1 parent 91171a0 commit ce7f297

File tree

2 files changed

+8
-2
lines changed

2 files changed

+8
-2
lines changed

prometheus_client/core.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -534,9 +534,9 @@ def init(name, documentation, labelnames=(), namespace='', subsystem='', registr
534534
raise ValueError('Reserved label metric name: ' + l)
535535
if l in cls._reserved_labelnames:
536536
raise ValueError('Reserved label metric name: ' + l)
537-
collector = _LabelWrapper(cls, name, labelnames, **kwargs)
537+
collector = _LabelWrapper(cls, full_name, labelnames, **kwargs)
538538
else:
539-
collector = cls(name, (), (), **kwargs)
539+
collector = cls(full_name, (), (), **kwargs)
540540

541541
if not _METRIC_NAME_RE.match(full_name):
542542
raise ValueError('Invalid metric name: ' + full_name)

tests/test_multiprocess.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -110,6 +110,12 @@ def test_gauge_livesum(self):
110110
mark_process_dead(123, os.environ['prometheus_multiproc_dir'])
111111
self.assertEqual(2, self.registry.get_sample_value('g'))
112112

113+
def test_namespace_subsystem(self):
114+
c1 = Counter('c', 'help', registry=None, namespace='ns', subsystem='ss')
115+
c1.inc(1)
116+
self.assertEqual(1, self.registry.get_sample_value('ns_ss_c'))
117+
118+
113119
class TestMmapedDict(unittest.TestCase):
114120
def setUp(self):
115121
fd, self.tempfile = tempfile.mkstemp()

0 commit comments

Comments
 (0)
0