diff --git a/tests/test_advanced_streaming.py b/tests/test_advanced_streaming.py index 82cc53a..8061c3b 100644 --- a/tests/test_advanced_streaming.py +++ b/tests/test_advanced_streaming.py @@ -364,7 +364,6 @@ def test_local_task_fanout_from_stream( 'inf_streamer', enable_modules=[__name__], ) - # with trio.fail_after(3): async with ( p.open_context(inf_streamer) as (ctx, _), ctx.open_stream() as stream, diff --git a/tractor/_root.py b/tractor/_root.py index 1d147dd..32cc3d5 100644 --- a/tractor/_root.py +++ b/tractor/_root.py @@ -343,9 +343,7 @@ async def open_root_actor( # tempn.start_soon(an.exited.wait) logger.cancel("Shutting down root actor") - await actor.cancel( - requesting_uid=actor.uid, - ) + await actor.cancel(None) # self cancel finally: _state._current_actor = None