diff --git a/packages/cloudflare/src/handler.ts b/packages/cloudflare/src/handler.ts index 3640d3cf7229..001ab55049ab 100644 --- a/packages/cloudflare/src/handler.ts +++ b/packages/cloudflare/src/handler.ts @@ -175,7 +175,10 @@ export function withSentry acc + message.attempts, 0), + 'messaging.message.retry.count': batch.messages.reduce( + (acc, message) => acc + message.attempts - 1, + 0, + ), [SEMANTIC_ATTRIBUTE_SENTRY_OP]: 'queue.process', [SEMANTIC_ATTRIBUTE_SENTRY_ORIGIN]: 'auto.faas.cloudflare.queue', [SEMANTIC_ATTRIBUTE_SENTRY_SOURCE]: 'task', diff --git a/packages/cloudflare/test/handler.test.ts b/packages/cloudflare/test/handler.test.ts index 2e5c0f836e89..ddd4b0010ec0 100644 --- a/packages/cloudflare/test/handler.test.ts +++ b/packages/cloudflare/test/handler.test.ts @@ -843,7 +843,7 @@ describe('withSentry', () => { 'messaging.destination.name': batch.queue, 'messaging.system': 'cloudflare', 'messaging.batch.message_count': batch.messages.length, - 'messaging.message.retry.count': batch.messages.reduce((acc, message) => acc + message.attempts, 0), + 'messaging.message.retry.count': batch.messages.reduce((acc, message) => acc + message.attempts - 1, 0), 'sentry.sample_rate': 1, 'sentry.source': 'task', },