From ec4b72259d015651746d87e51b06db02f3d72243 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Thu, 13 Apr 2023 17:24:27 -0400 Subject: [PATCH] Drop brackpressure usage from fan out tests --- tests/test_task_broadcasting.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/tests/test_task_broadcasting.py b/tests/test_task_broadcasting.py index 9f4a1fe..5e18e10 100644 --- a/tests/test_task_broadcasting.py +++ b/tests/test_task_broadcasting.py @@ -86,7 +86,7 @@ async def open_sequence_streamer( ) as (ctx, first): assert first is None - async with ctx.open_stream(backpressure=True) as stream: + async with ctx.open_stream(allow_overruns=True) as stream: yield stream await portal.cancel_actor() @@ -413,8 +413,8 @@ def test_ensure_slow_consumers_lag_out( seq = brx._state.subs[brx.key] assert seq == len(brx._state.queue) - 1 - # all backpressured entries in the underlying - # channel should have been copied into the caster + # all no_overruns entries in the underlying + # channel should have been copied into the bcaster # queue trailing-window async for i in rx: print(f'bped: {i}')