diff --git a/tests/test_context_stream_semantics.py b/tests/test_context_stream_semantics.py index 6d7de4d6..5548ed17 100644 --- a/tests/test_context_stream_semantics.py +++ b/tests/test_context_stream_semantics.py @@ -115,10 +115,12 @@ async def not_started_but_stream_opened( ) def test_started_misuse( target: Callable, + reg_addr: tuple, debug_mode: bool, ): async def main(): async with tractor.open_nursery( + registry_addrs=[reg_addr], debug_mode=debug_mode, ) as an: portal = await an.start_actor( @@ -184,6 +186,7 @@ def test_simple_context( error_parent, child_blocks_forever, pointlessly_open_stream, + reg_addr: tuple, debug_mode: bool, ): @@ -193,6 +196,7 @@ def test_simple_context( with trio.fail_after(timeout): async with tractor.open_nursery( + registry_addrs=[reg_addr], debug_mode=debug_mode, ) as an: portal = await an.start_actor( @@ -278,6 +282,7 @@ def test_parent_cancels( cancel_method: str, chk_ctx_result_before_exit: bool, child_returns_early: bool, + reg_addr: tuple, debug_mode: bool, ): ''' @@ -355,6 +360,7 @@ def test_parent_cancels( async def main(): async with tractor.open_nursery( + registry_addrs=[reg_addr], debug_mode=debug_mode, ) as an: portal = await an.start_actor( @@ -931,6 +937,7 @@ async def keep_sending_from_child( ) def test_one_end_stream_not_opened( overrun_by: tuple[str, int, Callable], + reg_addr: tuple, debug_mode: bool, ): ''' @@ -949,6 +956,7 @@ def test_one_end_stream_not_opened( async def main(): async with tractor.open_nursery( + registry_addrs=[reg_addr], debug_mode=debug_mode, ) as an: portal = await an.start_actor( @@ -1113,6 +1121,7 @@ def test_maybe_allow_overruns_stream( # conftest wide loglevel: str, + reg_addr: tuple, debug_mode: bool, ): ''' @@ -1133,6 +1142,7 @@ def test_maybe_allow_overruns_stream( ''' async def main(): async with tractor.open_nursery( + registry_addrs=[reg_addr], debug_mode=debug_mode, ) as an: portal = await an.start_actor( @@ -1249,6 +1259,7 @@ def test_maybe_allow_overruns_stream( def test_ctx_with_self_actor( loglevel: str, + reg_addr: tuple, debug_mode: bool, ): ''' @@ -1263,6 +1274,7 @@ def test_ctx_with_self_actor( ''' async def main(): async with tractor.open_nursery( + registry_addrs=[reg_addr], debug_mode=debug_mode, enable_modules=[__name__], ) as an: