diff --git a/relay-server/src/services/processor.rs b/relay-server/src/services/processor.rs index 44e2400d14..e866866119 100644 --- a/relay-server/src/services/processor.rs +++ b/relay-server/src/services/processor.rs @@ -1464,31 +1464,7 @@ impl EnvelopeProcessorService { &self, state: &mut ProcessEnvelopeState, ) -> Result<(), ProcessingError> { - let attachment_type = state - .envelope() - .get_item_by(|item| item.attachment_type().is_some()) - .and_then(|item| item.attachment_type()) - .map(|ty| ty.to_string()); - let event_type = state - .event - .value() - .and_then(|e| e.ty.value()) - .map(|ty| ty.as_str()) - .unwrap_or("none"); - if !state.has_event() { - metric!( - counter(RelayCounters::NormalizationDecision) += 1, - event_type = event_type, - attachment_type = attachment_type.as_deref().unwrap_or("none"), - origin = if state.envelope().meta().is_from_internal_relay() { - "internal" - } else { - "external" - }, - decision = "no_event" - ); - // NOTE(iker): only processing relays create events from // attachments, so these events won't be normalized in // non-processing relays even if the config is set to run full @@ -1500,39 +1476,12 @@ impl EnvelopeProcessorService { NormalizationLevel::Full => true, NormalizationLevel::Default => { if self.inner.config.processing_enabled() && state.event_fully_normalized { - metric!( - counter(RelayCounters::NormalizationDecision) += 1, - event_type = event_type, - attachment_type = attachment_type.as_deref().unwrap_or("none"), - origin = if state.envelope().meta().is_from_internal_relay() { - "internal" - } else { - "external" - }, - decision = "skip_normalized" - ); return Ok(()); - } else { - self.inner.config.processing_enabled() } - } - }; - metric!( - counter(RelayCounters::NormalizationDecision) += 1, - event_type = event_type, - attachment_type = attachment_type.as_deref().unwrap_or("none"), - origin = if state.envelope().meta().is_from_internal_relay() { - "internal" - } else { - "external" - }, - decision = if full_normalization { - "full_normalization" - } else { - "limited_normalization" + self.inner.config.processing_enabled() } - ); + }; let request_meta = state.managed_envelope.envelope().meta(); let client_ipaddr = request_meta.client_addr().map(IpAddr::from); diff --git a/relay-server/src/statsd.rs b/relay-server/src/statsd.rs index 892d14d36b..903ac18a97 100644 --- a/relay-server/src/statsd.rs +++ b/relay-server/src/statsd.rs @@ -769,12 +769,6 @@ pub enum RelayCounters { /// The amount of times metrics of a project have been flushed without the project being /// fetched/available. ProjectStateFlushMetricsNoProject, - /// The decision on whether normalization should run for an event. - /// - /// This metric is tagged with: - /// - `decision`: the decision relay makes on the event. - /// - `attachment_type`: the type of the attachment in the envelope. - NormalizationDecision, } impl CounterMetric for RelayCounters { @@ -818,7 +812,6 @@ impl CounterMetric for RelayCounters { RelayCounters::FeedbackAttachments => "processing.feedback_attachments", RelayCounters::CogsUsage => "cogs.usage", RelayCounters::ProjectStateFlushMetricsNoProject => "project_state.metrics.no_project", - RelayCounters::NormalizationDecision => "normalization.decision", } } }