Compare commits

..

No commits in common. "1dd9c4ae75d161be8164d400632e35b6b240a2d6" and "aaba2983614c44318e95556eb2bf789b2c09a075" have entirely different histories.

5 changed files with 17 additions and 32 deletions

View File

@ -939,7 +939,6 @@ async def tell_little_bro(
def test_peer_spawns_and_cancels_service_subactor(
debug_mode: bool,
raise_client_error: str,
reg_addr: tuple[str, int],
):
# NOTE: this tests for the modden `mod wks open piker` bug
# discovered as part of implementing workspace ctx
@ -957,7 +956,6 @@ def test_peer_spawns_and_cancels_service_subactor(
async with tractor.open_nursery(
# NOTE: to halt the peer tasks on ctxc, uncomment this.
debug_mode=debug_mode,
registry_addrs=[reg_addr],
) as an:
server: Portal = await an.start_actor(
(server_name := 'spawn_server'),

View File

@ -35,10 +35,7 @@ from ._portal import (
open_portal,
LocalPortal,
)
from ._state import (
current_actor,
_runtime_vars,
)
from ._state import current_actor, _runtime_vars
if TYPE_CHECKING:
@ -208,11 +205,7 @@ async def find_actor(
# every call since something may change it globally (eg.
# like in our discovery test suite)!
from . import _root
registry_addrs = (
_runtime_vars['_registry_addrs']
or
_root._default_lo_addrs
)
registry_addrs = _root._default_lo_addrs
maybe_portals: list[
AsyncContextManager[tuple[str, int]]

View File

@ -109,11 +109,7 @@ async def open_root_actor(
_state._runtime_vars['_is_root'] = True
# caps based rpc list
enable_modules = (
enable_modules
or
[]
)
enable_modules = enable_modules or []
if rpc_module_paths:
warnings.warn(

View File

@ -257,7 +257,6 @@ class Actor:
self._reg_addrs: list[tuple[str, int]] = []
if registry_addrs:
self.reg_addrs: list[tuple[str, int]] = registry_addrs
_state._runtime_vars['_registry_addrs'] = registry_addrs
@property
def reg_addrs(self) -> list[tuple[str, int]]:

View File

@ -33,8 +33,7 @@ _last_actor_terminated: Actor|None = None
_runtime_vars: dict[str, Any] = {
'_debug_mode': False,
'_is_root': False,
'_root_mailbox': (None, None),
'_registry_addrs': [],
'_root_mailbox': (None, None)
}