From 9a73d605bf64ad6e58be581000d36923d9644770 Mon Sep 17 00:00:00 2001
From: Markus Unterwaditzer <markus-tarpit+git@unterwaditzer.net>
Date: Wed, 22 Apr 2026 18:25:41 +0200
Subject: [PATCH] fix(spans): Enable better_backpressure in span buffer RunTask

Ref STREAM-881
---
 pyproject.toml                                | 2 +-
 src/sentry/spans/consumers/process/factory.py | 1 +
 uv.lock                                       | 6 +++---
 3 files changed, 5 insertions(+), 4 deletions(-)

diff --git a/pyproject.toml b/pyproject.toml
index 6fabf74b0f6e46..1dfb4451030d5c 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -82,7 +82,7 @@ dependencies = [
   "rfc3339-validator>=0.1.2",
   "rfc3986-validator>=0.1.1",
   # [end] jsonschema format validators
-  "sentry-arroyo>=2.38.7",
+  "sentry-arroyo>=2.39.0",
   "sentry-conventions>=0.3.0",
   "sentry-forked-email-reply-parser>=0.5.12.post1",
   "sentry-kafka-schemas>=2.1.27",
diff --git a/src/sentry/spans/consumers/process/factory.py b/src/sentry/spans/consumers/process/factory.py
index 4eae1fa8cba7be..6d859636288880 100644
--- a/src/sentry/spans/consumers/process/factory.py
+++ b/src/sentry/spans/consumers/process/factory.py
@@ -121,6 +121,7 @@ def create_with_partitions(
                     buffer,
                 ),
                 next_step=flusher,
+                better_backpressure=True,
             )
 
         batch = BatchStep(
diff --git a/uv.lock b/uv.lock
index 35e7bd583da389..c6c8ad221a1cb9 100644
--- a/uv.lock
+++ b/uv.lock
@@ -2323,7 +2323,7 @@ requires-dist = [
     { name = "requests-oauthlib", specifier = ">=1.2.0" },
     { name = "rfc3339-validator", specifier = ">=0.1.2" },
     { name = "rfc3986-validator", specifier = ">=0.1.1" },
-    { name = "sentry-arroyo", specifier = ">=2.38.7" },
+    { name = "sentry-arroyo", specifier = ">=2.39.0" },
     { name = "sentry-conventions", specifier = ">=0.3.0" },
     { name = "sentry-forked-email-reply-parser", specifier = ">=0.5.12.post1" },
     { name = "sentry-kafka-schemas", specifier = ">=2.1.27" },
@@ -2415,13 +2415,13 @@ dev = [
 
 [[package]]
 name = "sentry-arroyo"
-version = "2.38.7"
+version = "2.39.0"
 source = { registry = "https://pypi.devinfra.sentry.io/simple" }
 dependencies = [
     { name = "confluent-kafka", marker = "sys_platform == 'darwin' or sys_platform == 'linux'" },
 ]
 wheels = [
-    { url = "https://pypi.devinfra.sentry.io/wheels/sentry_arroyo-2.38.7-py3-none-any.whl", hash = "sha256:088f8620e1fa6af950d588e4ddae259b849fb799af9a78dd5b9912ccedd19a4a" },
+    { url = "https://pypi.devinfra.sentry.io/wheels/sentry_arroyo-2.39.0-py3-none-any.whl", hash = "sha256:fb5fce90a6eb2aede72cfa6511133d8bbe9b3b83a83ee50105d604ef5c05164d" },
 ]
 
 [[package]]