File tree Expand file tree Collapse file tree 3 files changed +5
-23
lines changed
Expand file tree Collapse file tree 3 files changed +5
-23
lines changed Original file line number Diff line number Diff 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 ( ) ;
Original file line number Diff line number Diff 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 )
Original file line number Diff line number Diff 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 ( ) ,
You can’t perform that action at this time.
0 commit comments