`_root`: drop unused `typing` import

Use `import <name> as <name>,` style over `__all__` in pkg mod
Log chan-server-startup failures via `.exception()`
2025-03-18 12:23:40 -04:00 · 2025-03-18 12:23:39 -04:00 · 2025-03-18 12:22:47 -04:00 · 2025-03-18 12:22:47 -04:00 · 2025-03-18 12:22:47 -04:00 · 2025-03-18 12:22:47 -04:00
2 changed files with 11 additions and 31 deletions
--- a/setup.py
+++ b/setup.py
@ -26,7 +26,7 @@ with open('docs/README.rst', encoding='utf-8') as f:
 setup(
    name="tractor",
    version='0.1.0a6dev0',  # alpha zone
-    description='structured concurrent `trio`-"actors"',
+    description='structured concurrrent `trio`-"actors"',
    long_description=readme,
    license='AGPLv3',
    author='Tyler Goodlet',
@ -39,7 +39,6 @@ setup(
        'tractor.experimental',  # wacky ideas
        'tractor.trionics',  # trio extensions
        'tractor.msg',  # lowlevel data types
-        'tractor.devx',  # "dev-experience"
    ],
    install_requires=[

@ -53,7 +52,6 @@ setup(
        # 'exceptiongroup',  # in stdlib as of 3.11!

        # tooling
-        'stackscope',
        'tricycle',
        'trio_typing',
        'colorlog',
@ -65,15 +63,16 @@ setup(
        # debug mode REPL
        'pdbp',

-        # TODO: distributed transport using
-        # linux kernel networking
-        # 'pyroute2',
-
        # pip ref docs on these specs:
        # https://pip.pypa.io/en/stable/reference/requirement-specifiers/#examples
        # and pep:
        # https://peps.python.org/pep-0440/#version-specifiers

+        # windows deps workaround for ``pdbpp``
+        # https://github.com/pdbpp/pdbpp/issues/498
+        # https://github.com/pdbpp/fancycompleter/issues/37
+        'pyreadline3 ; platform_system == "Windows"',
+
    ],
    tests_require=['pytest'],
    python_requires=">=3.10",
--- a/tractor/_root.py
+++ b/tractor/_root.py
@ -139,19 +139,13 @@ async def open_root_actor(
    )
    assert registry_addrs

-    loglevel = (
-        loglevel
-        or log._default_loglevel
-    ).upper()
+    loglevel = (loglevel or log._default_loglevel).upper()

-    if (
-        debug_mode
-        and _spawn._spawn_method == 'trio'
-    ):
+    if debug_mode and _spawn._spawn_method == 'trio':
        _state._runtime_vars['_debug_mode'] = True

-        # expose internal debug module to every actor allowing for
-        # use of ``await tractor.pause()``
+        # expose internal debug module to every actor allowing
+        # for use of ``await tractor.breakpoint()``
        enable_modules.append('tractor.devx._debug')

        # if debug mode get's enabled *at least* use that level of
@ -170,20 +164,7 @@ async def open_root_actor(
            "Debug mode is only supported for the `trio` backend!"
        )

-    assert loglevel
-    _log = log.get_console_log(loglevel)
-    assert _log
-
-    # TODO: factor this into `.devx._stackscope`!!
-    if debug_mode:
-        try:
-            logger.info('Enabling `stackscope` traces on SIGUSR1')
-            from .devx import enable_stack_on_sig
-            enable_stack_on_sig()
-        except ImportError:
-            logger.warning(
-                '`stackscope` not installed for use in debug mode!'
-            )
+    log.get_console_log(loglevel)

    # closed into below ping task-func
    ponged_addrs: list[tuple[str, int]] = []
Author	SHA1	Message	Date
Tyler Goodlet	4d675deb24	`_root`: drop unused `typing` import	2025-03-18 12:23:40 -04:00
Tyler Goodlet	31297171fc	Use `import <name> as <name>,` style over `__all__` in pkg mod	2025-03-18 12:23:39 -04:00
Tyler Goodlet	d7a9ddd4a9	Log chan-server-startup failures via `.exception()`	2025-03-18 12:22:47 -04:00
Tyler Goodlet	43b84c99b6	`.discovery.get_arbiter()`: add warning around this now deprecated usage	2025-03-18 12:22:47 -04:00
Tyler Goodlet	b7f2258f15	Add `open_root_actor(ensure_registry: bool)` Allows forcing the opened actor to either obtain the passed registry addrs or raise a runtime error.	2025-03-18 12:22:47 -04:00
Tyler Goodlet	1dfa109879	Fix doc string "its" typo..	2025-03-18 12:22:47 -04:00
Tyler Goodlet	0453e3565e	Test with `any(portals)` since `gather_contexts()` will return `list[None \| tuple]`	2025-03-18 12:22:47 -04:00
Tyler Goodlet	0bf13c50b4	Change remaining internals to use `Actor.reg_addrs`	2025-03-18 12:22:25 -04:00
Tyler Goodlet	2e69aa0f67	Expose per-actor registry addrs via `.reg_addrs` Since it's handy to be able to debug the writing of this instance var (particularly when checking state passed down to a child in `Actor._from_parent()`), rename and wrap the underlying `Actor._reg_addrs` as a settable `@property` and add validation to the `.setter` for sanity - actor discovery is a critical functionality. Other tweaks: - fix `.cancel_soon()` to pass expected argument.. - update internal runtime error message to be simpler and link to GH issues. - use new `Actor.reg_addrs` throughout core.	2025-03-18 12:22:25 -04:00
Tyler Goodlet	fc9c7e6e3f	Get remaining suites passing.. ..by ensuring `reg_addr` fixture value passthrough to subactor eps	2025-03-18 12:22:25 -04:00
Tyler Goodlet	354a4c2226	Always dynamically re-read the `._root._default_lo_addrs` value in `find_actor()`	2025-03-18 12:22:25 -04:00
Tyler Goodlet	d2c88e9709	Ensure `registry_addrs` is always set to something	2025-03-18 12:22:25 -04:00
Tyler Goodlet	ef179b69f2	Rename fixture `arb_addr` -> `reg_addr` and set the session value globally as `._root._default_lo_addrs`	2025-03-18 12:22:25 -04:00
Tyler Goodlet	837602a011	Facepalm, `wait_for_actor()` dun take an addr `list`..	2025-03-18 12:22:25 -04:00
Tyler Goodlet	debacef30e	._root: set a `_default_lo_addrs` and apply it when not provided by caller	2025-03-18 12:21:47 -04:00
Tyler Goodlet	7ae405ef5a	Always set default reg addr in `find_actor()` if not defined	2025-03-18 12:21:47 -04:00
Tyler Goodlet	e428bf0a34	Oof, default reg addrs needs to be in `list[tuple]` form..	2025-03-18 12:21:47 -04:00
Tyler Goodlet	d448bb81bd	Add post-mortem catch around failed transport addr binds to aid with runtime debugging	2025-03-18 12:21:47 -04:00
Tyler Goodlet	77108a9759	Rename to `parse_maddr()` and fill out doc strings	2025-03-18 12:21:47 -04:00
Tyler Goodlet	1720fefa1d	Add libp2p style "multi-address" parser from `piker` Details are in the module docs; this is a first draft with lotsa room for refinement and extension.	2025-03-18 12:21:47 -04:00
Tyler Goodlet	a3c1f8e419	Init-support for "multi homed" transports Since we'd like to eventually allow a diverse set of transport (protocol) methods and stacks, and a multi-peer discovery system for distributed actor-tree applications, this reworks all runtime internals to support multi-homing for any given tree on a logical host. In other words any actor can now bind its transport server (currently only unsecured TCP + `msgspec`) to more then one address available in its (linux) network namespace. Further, registry actors (now dubbed "registars" instead of "arbiters") can also similarly bind to multiple network addresses and provide discovery services to remote actors via multiple addresses which can now be provided at runtime startup. Deats: - adjust `._runtime` internals to use a `list[tuple[str, int]]` (and thus pluralized) socket address sequence where applicable for transport server socket binds, now exposed via `Actor.accept_addrs`: - `Actor.__init__()` now takes a `registry_addrs: list`. - `Actor.is_arbiter` -> `.is_registrar`. - `._arb_addr` -> `._reg_addrs: list[tuple]`. - always reg and de-reg from all registrars in `async_main()`. - only set the global runtime var `'_root_mailbox'` to the loopback address since normally all in-tree processes should have access to it, right? - `._serve_forever()` task now takes `listen_sockaddrs: list[tuple]` - make `open_root_actor()` take a `registry_addrs: list[tuple[str, int]]` and defaults when not passed. - change `ActorNursery.start_..()` methods take `bind_addrs: list` and pass down through the spawning layer(s) via the parent-seed-msg. - generalize all `._discovery()` APIs to accept `registry_addrs`-like inputs and move all relevant subsystems to adopt the "registry" style naming instead of "arbiter": - make `find_actor()` support batched concurrent portal queries over all provided input addresses using `.trionics.gather_contexts()` Bo - syntax: move to using `async with <tuples>` 3.9+ style chained @acms. - a general modernization of the code to a python 3.9+ style. - start deprecation and change to "registry" naming / semantics: - `._discovery.get_arbiter()` -> `.get_registry()`	2025-03-18 12:21:45 -04:00