Fix cluster test to use `allow_overruns`

2023-04-13 17:48:57 -04:00 · 2023-04-13 17:48:57 -04:00 · f1e9c0be93
parent 6db656fecf
commit f1e9c0be93
1 changed files with 1 additions and 1 deletions
--- 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?