Page MenuHomeSoftware Heritage
Files F9312601

D1297.id4099.diff
No OneTemporary
Actions

D1297.id4099.diff
View Options

diff --git a/swh/core/statsd.py b/swh/core/statsd.py
--- a/swh/core/statsd.py
+++ b/swh/core/statsd.py
@@ -73,9 +73,13 @@
Attributes:
elapsed (float): the elapsed time at the point of completion
"""
- def __init__(self, statsd, metric=None, tags=None, sample_rate=1):
+ def __init__(self, statsd, metric=None, error_metric=None,
+ tags=None, sample_rate=1):
self.statsd = statsd
self.metric = metric
+ self.error_metric = error_metric
+ if self.error_metric is None:
+ self.error_metric = self.metric + '_error_count'
self.tags = tags
self.sample_rate = sample_rate
self.elapsed = None
@@ -97,8 +101,13 @@
try:
result = await func(*args, **kwargs)
return result
+ except: # noqa
+ self._send_error()
+ start = None
+ raise
finally:
- self._send(start)
+ if start is not None:
+ self._send(start)
return wrapped_co
# Others
@@ -107,8 +116,13 @@
start = monotonic()
try:
return func(*args, **kwargs)
+ except: # noqa
+ self._send_error()
+ start = None
+ raise
finally:
- self._send(start)
+ if start is not None:
+ self._send(start)
return wrapped
def __enter__(self):
@@ -118,14 +132,21 @@
return self
def __exit__(self, type, value, traceback):
- # Report the elapsed time of the context manager.
- self._send(self._start)
+ # Report the elapsed time of the context manager if no error.
+ if type is None:
+ self._send(self._start)
+ else:
+ self._send_error()
def _send(self, start):
elapsed = (monotonic() - start) * 1000
- self.statsd.timing(self.metric, elapsed, self.tags, self.sample_rate)
+ self.statsd.timing(self.metric, int(elapsed),
+ tags=self.tags, sample_rate=self.sample_rate)
self.elapsed = elapsed
+ def _send_error(self):
+ self.statsd.increment(self.error_metric, tags=self.tags)
+
def start(self):
"""Start the timer"""
self.__enter__()
@@ -192,7 +213,6 @@
UserWarning,
)
continue
- print(tag)
k, v = tag.split(':', 1)
self.constant_tags[k] = v
@@ -262,7 +282,7 @@
"""
self._report(metric, 'ms', value, tags, sample_rate)
- def timed(self, metric=None, tags=None, sample_rate=1):
+ def timed(self, metric=None, error_metric=None, tags=None, sample_rate=1):
"""
A decorator or context manager that will measure the distribution of a
function's/context's run time. Optionally specify a list of tags or a
@@ -288,7 +308,10 @@
finally:
statsd.timing('user.query.time', time.monotonic() - start)
"""
- return TimedContextManagerDecorator(self, metric, tags, sample_rate)
+ return TimedContextManagerDecorator(
+ statsd=self, metric=metric,
+ error_metric=error_metric,
+ tags=tags, sample_rate=sample_rate)
def set(self, metric, value, tags=None, sample_rate=1):
"""
@@ -369,7 +392,6 @@
for (k, v) in sorted(tags.items())
)) if tags else "",
)
-
# Send it
self._send(payload)

File Metadata

Mime Type
text/plain
Expires
Wed, Jul 2, 10:59 AM (1 w, 4 d ago)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
3233965

Event Timeline

About · Developer information · Legal