From f1e9c0be93bbed36880769e0ab00f08029cf8489 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Thu, 13 Apr 2023 17:48:57 -0400
Subject: [PATCH] Fix cluster test to use `allow_overruns`

---
 tests/test_clustering.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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?