Rename `discovery._discovery` to `._api`

Adjust all imports to match.

(this commit msg was generated in some part by [`claude-code`][claude-code-gh])
[claude-code-gh]: https://github.com/anthropics/claude-code
subint_spawner_backend
Gud Boi 2026-04-14 12:27:04 -04:00
parent cb7b76c44f
commit c3d6cc9007
8 changed files with 7 additions and 7 deletions

View File

@ -552,7 +552,7 @@ def test_stale_entry_is_deleted(
registry_addrs=[reg_addr], registry_addrs=[reg_addr],
) as maybe_portal: ) as maybe_portal:
# because the transitive # because the transitive
# `._discovery.maybe_open_portal()` call should # `._api.maybe_open_portal()` call should
# fail and implicitly call `.delete_addr()` # fail and implicitly call `.delete_addr()`
assert maybe_portal is None assert maybe_portal is None
registry: dict = await unpack_reg(_reg_ptl) registry: dict = await unpack_reg(_reg_ptl)

View File

@ -122,7 +122,7 @@ async def get_root_portal(
# connect back to our immediate parent which should also # connect back to our immediate parent which should also
# be the actor-tree's root. # be the actor-tree's root.
from tractor.discovery._discovery import get_root from tractor.discovery._api import get_root
ptl: Portal ptl: Portal
async with get_root() as ptl: async with get_root() as ptl:
root_aid: Aid = ptl.chan.aid root_aid: Aid = ptl.chan.aid

View File

@ -30,7 +30,7 @@ from ._streaming import (
MsgStream as MsgStream, MsgStream as MsgStream,
stream as stream, stream as stream,
) )
from .discovery._discovery import ( from .discovery._api import (
get_registry as get_registry, get_registry as get_registry,
find_actor as find_actor, find_actor as find_actor,
wait_for_actor as wait_for_actor, wait_for_actor as wait_for_actor,

View File

@ -1013,7 +1013,7 @@ async def request_root_stdio_lock(
DebugStatus.req_task = current_task() DebugStatus.req_task = current_task()
req_err: BaseException|None = None req_err: BaseException|None = None
try: try:
from tractor.discovery._discovery import get_root from tractor.discovery._api import get_root
# NOTE: we need this to ensure that this task exits # NOTE: we need this to ensure that this task exits
# BEFORE the REPl instance raises an error like # BEFORE the REPl instance raises an error like
# `bdb.BdbQuit` directly, OW you get a trio cs stack # `bdb.BdbQuit` directly, OW you get a trio cs stack

View File

@ -21,7 +21,7 @@ and location management of (service) actors.
NOTE: to avoid circular imports, this ``__init__`` NOTE: to avoid circular imports, this ``__init__``
does NOT eagerly import submodules. Use direct does NOT eagerly import submodules. Use direct
module paths like ``tractor.discovery._addr`` or module paths like ``tractor.discovery._addr`` or
``tractor.discovery._discovery`` instead. ``tractor.discovery._api`` instead.
''' '''
from ._multiaddr import ( from ._multiaddr import (

View File

@ -274,7 +274,7 @@ async def maybe_wait_on_canced_subs(
# ephemeral `.register_actor()` request! # ephemeral `.register_actor()` request!
# -[ ] also, that should be avoidable by # -[ ] also, that should be avoidable by
# re-using any existing chan from the # re-using any existing chan from the
# `._discovery.get_registry()` call as # `._api.get_registry()` call as
# well.. # well..
log.runtime( log.runtime(
f'Peer IPC broke but subproc is alive?\n\n' f'Peer IPC broke but subproc is alive?\n\n'

View File

@ -115,7 +115,7 @@ from ..devx import (
debug, debug,
pformat as _pformat pformat as _pformat
) )
from ..discovery._discovery import get_registry from ..discovery._api import get_registry
from ._portal import Portal from ._portal import Portal
from . import _state from . import _state
from ..spawn import _mp_fixup_main from ..spawn import _mp_fixup_main