From 7b9c56c0a30cfebe27a069e0e1733ef4b62385fe Mon Sep 17 00:00:00 2001 From: Riya Chakraborty <47572810+ayirr7@users.noreply.github.com> Date: Fri, 13 Sep 2024 11:22:56 -0700 Subject: [PATCH] =?UTF-8?q?Revert=20"metric(consumer):=20Add=20a=20metric?= =?UTF-8?q?=20to=20track=20the=20size=20of=20individual=20spans=20?= =?UTF-8?q?=E2=80=A6"?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit This reverts commit d789447ee79e4fd64b120d9859cbe17530bfd165. --- rust_snuba/src/processors/spans.rs | 3 --- 1 file changed, 3 deletions(-) diff --git a/rust_snuba/src/processors/spans.rs b/rust_snuba/src/processors/spans.rs index eefe8a11a1..49a1f7e398 100644 --- a/rust_snuba/src/processors/spans.rs +++ b/rust_snuba/src/processors/spans.rs @@ -3,7 +3,6 @@ use std::str::FromStr; use anyhow::Context; use chrono::DateTime; -use rust_arroyo::timer; use schemars::JsonSchema; use serde::{Deserialize, Serialize}; use uuid::Uuid; @@ -23,8 +22,6 @@ pub fn process_message( let payload_bytes = payload.payload().context("Expected payload")?; let msg: FromSpanMessage = serde_json::from_slice(payload_bytes)?; - timer!("spans.messages.size", payload_bytes.len() as f64); - let origin_timestamp = DateTime::from_timestamp(msg.received as i64, 0); let mut span: Span = msg.try_into()?;