From f3432bd8fbbc31725bc4ccb6ad1887fb08880173 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Sun, 5 Dec 2021 20:02:55 -0500 Subject: [PATCH] Enable bp on clustering test --- 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 ba8052f..56e629b 100644 --- a/tests/test_clustering.py +++ b/tests/test_clustering.py @@ -14,7 +14,7 @@ MESSAGE = 'tractoring at full speed' @tractor.context async def worker(ctx: tractor.Context) -> None: await ctx.started() - async with ctx.open_stream() as stream: + async with ctx.open_stream(backpressure=True) as stream: async for msg in stream: # do something with msg print(msg)