Skip to content

Commit fe9e018

Browse files
committed
Log runtime version
1 parent d553cb3 commit fe9e018

File tree

3 files changed

+5
-23
lines changed

3 files changed

+5
-23
lines changed

bottlecap/src/flushing/service.rs

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -98,20 +98,6 @@ impl FlushingService {
9898
let series = flush_response.series;
9999
let sketches = flush_response.distributions;
100100

101-
debug!(
102-
"FLUSHING_SERVICE | flushing {} series batch(es) and {} sketch batch(es)",
103-
series.len(),
104-
sketches.len()
105-
);
106-
for (i, sketch_payload) in sketches.iter().enumerate() {
107-
for sketch in &sketch_payload.sketches {
108-
debug!(
109-
"FLUSHING_SERVICE | sketch batch[{}]: metric='{}' tags={:?}",
110-
i, sketch.metric, sketch.tags
111-
);
112-
}
113-
}
114-
115101
for (idx, flusher) in self.metrics_flushers.iter().enumerate() {
116102
let flusher = flusher.clone();
117103
let series_clone = series.clone();

bottlecap/src/lifecycle/invocation/processor.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -285,11 +285,11 @@ impl Processor {
285285
/// This is used to create a cold start span, since this telemetry event does not
286286
/// provide a `request_id`, we try to guess which invocation is the cold start.
287287
pub fn on_platform_init_start(&mut self, time: DateTime<Utc>, runtime_version: Option<String>) {
288-
if runtime_version
289-
.as_deref()
290-
.is_some_and(|rv| rv.contains("DurableFunction"))
291-
{
292-
self.enhanced_metrics.set_durable_function_tag();
288+
if let Some(ref rv) = runtime_version {
289+
debug!("Runtime version: {}", rv);
290+
if rv.contains("DurableFunction") {
291+
self.enhanced_metrics.set_durable_function_tag();
292+
}
293293
}
294294
let start_time: i64 = SystemTime::from(time)
295295
.duration_since(UNIX_EPOCH)

bottlecap/src/metrics/enhanced/lambda.rs

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -152,10 +152,6 @@ impl Lambda {
152152
if !self.config.enhanced_metrics {
153153
return;
154154
}
155-
debug!(
156-
"Enhanced metrics: creating metric '{}' with dynamic_value_tags: {:?}",
157-
metric_name, self.dynamic_value_tags
158-
);
159155
let tags = self.get_dynamic_value_tags();
160156
let metric = Metric::new(
161157
metric_name.into(),

0 commit comments

Comments
 (0)