From 8d9ad6bac9071f04c791f814c9b93c60b3b39ce8 Mon Sep 17 00:00:00 2001 From: overclockworked64 Date: Fri, 22 Oct 2021 03:10:46 +0200 Subject: [PATCH] Get rid of external teardown trigger --- tests/test_clustering.py | 4 ---- 1 file changed, 4 deletions(-) diff --git a/tests/test_clustering.py b/tests/test_clustering.py index 8f28d85..1e85d04 100644 --- a/tests/test_clustering.py +++ b/tests/test_clustering.py @@ -23,19 +23,15 @@ async def worker(ctx: tractor.Context) -> None: @tractor_test async def test_streaming_to_actor_cluster() -> None: - teardown_trigger = trio.Event() async with ( open_actor_cluster(modules=[__name__]) as portals, async_enter_all( mngrs=[p.open_context(worker) for p in portals.values()], - teardown_trigger=teardown_trigger, ) as contexts, async_enter_all( mngrs=[ctx[0].open_stream() for ctx in contexts], - teardown_trigger=teardown_trigger, ) as streams, ): with trio.move_on_after(1): for stream in itertools.cycle(streams): await stream.send(MESSAGE) - teardown_trigger.set() \ No newline at end of file