From 74a0127bb96bc7fb378202ba95af81816bcf19e9 Mon Sep 17 00:00:00 2001 From: David Herberth Date: Thu, 1 Oct 2026 09:02:36 +0200 Subject: [PATCH] ref(cogs): Remove submit category tracking --- relay-server/src/services/processor.rs | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) diff --git a/relay-server/src/services/processor.rs b/relay-server/src/services/processor.rs index c038dbb3ec6..6a11ef29e38 100644 --- a/relay-server/src/services/processor.rs +++ b/relay-server/src/services/processor.rs @@ -702,8 +702,7 @@ impl EnvelopeProcessorService { } if let Some(output) = main { - // Only counting processing time for COGS at the moment. - self.submit_upstream(&mut Token::noop(), output, ctx); + self.submit_upstream(output, ctx); } if let Some(intermediates) = intermediates { @@ -818,14 +817,7 @@ impl EnvelopeProcessorService { /// Submits a processor [`Output`] to the appropriate upstream. /// /// If processing is enabled, the upstream is Kafka. - fn submit_upstream( - &self, - cogs: &mut Token, - output: Outputs, - ctx: processing::ForwardContext<'_>, - ) { - let _submit = cogs.start_category("submit"); - + fn submit_upstream(&self, output: Outputs, ctx: processing::ForwardContext<'_>) { #[cfg(feature = "processing")] if ctx.config.processing_enabled() && let Some(store_forwarder) = &self.inner.addrs.store_forwarder