summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJames E. Blair <jim@acmegating.com>2021-03-17 15:03:18 -0700
committerJames E. Blair <jim@acmegating.com>2021-03-17 15:03:18 -0700
commit4bb45bf2a0223c1c624dbd8f44efff207e6b4097 (patch)
treea274b354d507d4b04bcd1f29587f2fd5dcddfc53
parent8a06dc90101c4b5285aaed858a62dadc5ae27868 (diff)
downloadzuul-4bb45bf2a0223c1c624dbd8f44efff207e6b4097.tar.gz
Report enqueue stats as ms4.1.0
The previous change to add new statsd metrics incorrectly reported them as seconds rather than milliseconds; correct that. Change-Id: I9d0dd293ef3d3fcee8025250ec628d85a52fba4e
-rw-r--r--zuul/manager/__init__.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/zuul/manager/__init__.py b/zuul/manager/__init__.py
index 27b6e9699..663114586 100644
--- a/zuul/manager/__init__.py
+++ b/zuul/manager/__init__.py
@@ -1564,8 +1564,9 @@ class PipelineManager(metaclass=ABCMeta):
self.sched.statsd.incr(key + '.total_changes')
if added and hasattr(item.event, 'arrived_at_scheduler_timestamp'):
now = time.time()
- processing = now - item.event.arrived_at_scheduler_timestamp
- elapsed = now - item.event.timestamp
+ arrived = item.event.arrived_at_scheduler_timestamp
+ processing = int((now - arrived) * 1000)
+ elapsed = int((now - item.event.timestamp) * 1000)
self.sched.statsd.timing(
basekey + '.event_enqueue_processing_time',
processing)