diff --git a/tests/test_clustering.py b/tests/test_clustering.py
index df3d835..02b1f8f 100644
--- a/tests/test_clustering.py
+++ b/tests/test_clustering.py
@@ -49,7 +49,7 @@ async def worker(
     await ctx.started()
 
     async with ctx.open_stream(
-        backpressure=True,
+        allow_overruns=True,
     ) as stream:
 
         # TODO: this with the below assert causes a hang bug?