Skip to content

Commit 911b942

Browse files
change rate calculation
1 parent c1bc06d commit 911b942

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

datadog/dogstatsd/max_sample_metric.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,10 +41,11 @@ def skip_sample(self):
4141
self.total_metric_samples += 1
4242

4343
def flush(self):
44+
rate = self.stored_metric_samples / self.total_metric_samples
4445
with self.lock:
4546
values = [None] * self.stored_metric_samples
4647
for i in range(self.stored_metric_samples):
47-
values[i] = MetricAggregator(self.name, self.tags, self.specified_rate, self.metric_type, self.data[i])
48+
values[i] = MetricAggregator(self.name, self.tags, rate, self.metric_type, self.data[i])
4849
return values
4950

5051

datadog/dogstatsd/max_sample_metric_context.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@ def sample(self, name, value, tags, rate, context_key, max_samples_per_context):
2424
with self.lock:
2525
if context_key not in self.values:
2626
# Create a new metric if it doesn't exist
27-
self.values[context_key] = self.max_sample_metric_type(name, tags, rate, max_samples_per_context)
27+
self.values[context_key] = self.max_sample_metric_type(name, tags, max_samples_per_context)
2828
metric = self.values[context_key]
2929
metric.lock.acquire()
3030
if keeping_sample:

0 commit comments

Comments
 (0)