Comparing ee79939dd3..7387bde030 - tractor - Pikers Dev

..

Author	SHA1	Message	Date
Gud Boi	7387bde030	Bump lockfile for `xonsh>=0.23.8` release	2026-06-22 15:19:34 -04:00
Gud Boi	2175045230	Code-style, couple newline/ws tweaks (cherry picked from commit `8526985c97`) (cherry picked from commit `0952b33a9e`)	2026-06-22 15:19:34 -04:00
Gud Boi	8a57dd033b	Pin to latest `xonsh` release (cherry picked from commit `c4cad921b9`) (cherry picked from commit `ade15b4204`)	2026-06-22 15:19:34 -04:00
Gud Boi	2d07d4ba91	Hoist proc-title prefix to `_def_prefix` const Make the sub-actor proc-title prefix a single authoritative constant (`_proctitle._def_prefix`) so the reap-recognition markers and `xontrib` banner pick it up automatically — one place to flip the prefix shape going fwd. Deats, - `_proctitle._def_prefix: str = '_subactor'`. New module-level const consumed by everything that needs to know the prefix. - `set_actor_proctitle(actor, prefix=_def_prefix)`: takes an explicit `prefix` arg (default = the const) so callers can override per-spawn if they want. - Default proc-title format: `'tractor[<reprol>]'` → `f'{prefix}[<reprol>]'` i.e. `_subactor[<reprol>]` by default. - `_testing/_reap.py`: cmdline + comm markers source the prefix from `_proctitle._def_prefix` instead of the hardcoded `'tractor['`. So `_is_tractor_subactor()` tracks the const automatically. - `xontrib/tractor_diag.xsh`: `acli.reap` orphan-mode banner now interpolates the `_TRACTOR_PROC_CMDLINE_MARKERS` tuple directly so the human-readable mode line stays in sync if the prefix shape changes again. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code (cherry picked from commit `3a45dbd503`) (cherry picked from commit `fd8d39c0ce`)	2026-06-22 15:19:34 -04:00
Gud Boi	d0afc69a1c	Add `add_log_level()` factory + register `IO`=21 Follow-up to `f595acc7` (`supervise_run_process`) which called `log.io(...)` for std-stream relay assuming an `IO=21` level existed. Add the registration via a new factory + tests covering both the factory and the new level. `add_log_level()` factory, - One call wires the four (otherwise hand-synced) pieces: - `CUSTOM_LEVELS[NAME]` — drives the `stacklevel` bump in `StackLevelAdapter.log()` + `get_logger()`'s per-level audit. - `logging.addLevelName()` — stdlib name registration. - `STD_PALETTE[NAME]` + `BOLD_PALETTE['bold'][NAME]` — color entries consumed by `get_console_log()`'s `ColoredFormatter` build. - Same-named (lowercase) emit method bound on `StackLevelAdapter` so `log.<name>('msg')` works + `get_logger()`'s per-level method audit passes. - Idempotent: re-registering an existing name is a no-op-ish refresh that won't clobber an already-bound method. - Method binding uses a default-arg `_level=value` so the level int is captured (not late-bound across multiple registrations). `IO=21` level (first user), - Purple. Used by `tractor.trionics._subproc`'s std-stream relay (see `f595acc7`). - Value 21 picked to sit just ABOVE stdlib `INFO`=20 so it's SHOWN BY DEFAULT at usual `info`/`devx` console levels — a `runtime`=15 relay would be silently filtered (footgun for daemon supervisors whose whole point is visibility). Still distinctly labeled + filterable. Tests (`tests/test_log_sys.py`), - `test_io_custom_level_registered`: validates the IO level is fully wired (`CUSTOM_LEVELS`, `addLevelName`, both palettes, `StackLevelAdapter.io()` callable); emits a record + sanity-asserts `21 >= INFO(20)`. - `test_add_log_level_pluggable`: registers a fresh `XLVL=19` (cyan) via `add_log_level()`, asserts all four wires + the bound `xlog.xlvl()` emit, then try/finally cleans up the module-global mutations so later `get_logger()` audits don't trip on a half-removed level. (this patch was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code (cherry picked from commit `7bd7dd50c7`) (cherry picked from commit `93558fe3c9`)	2026-06-22 15:19:34 -04:00
Gud Boi	48cab20825	Strip ANSI + accept `_create(...)` in devx tests Two version-compat fixes for the `devx` debugger test-suite, both about matching upstream output that got more verbose w/ recent lib releases. ANSI stripping (`tests/devx/conftest.py`), - Add `ansi_strip(text)` helper + `_ansi_re` pattern (regex per https://stackoverflow.com/a/14693789). - Apply inside `in_prompt_msg()` + `assert_before()` so substring matches against REPL/traceback output stay robust to color leakage. - Motivated by py3.13's colored tracebacks + `pdbp`/pygments highlighting leaking ANSI even when `PYTHON_COLORS=0` is set in the `spawn` fixture (not every renderer in the spawned subproc honors it). - Replaces the longstanding inline TODO that linked the SO answer w/o impl'ing. trio 0.30+ `Cancelled._create(` match (`test_debugger`), - In `test_shield_pause` swap the two `"raise Cancelled._create()"` assertion patterns → `"raise Cancelled._create("` (open-paren form, no closing). - trio >=0.30 raises a multi-line `raise Cancelled._create(source=.., reason=.., source_task=..)` w/ cancel-reason metadata, so the legacy bare-`()` form no longer matches. Inline comment documents the trio-version pivot. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code (cherry picked from commit `3854cf5ecb`) (cherry picked from commit `c07cf2546b`)	2026-06-22 15:19:34 -04:00
Gud Boi	cc19c1f9c7	Add `supervise_run_process` to `trionics._subproc` A `trio.Nursery.start()`-style wrapper around `trio.run_process()` that surfaces rc!=0 errors deterministically, ALWAYS isolates the parent controlling-tty, and optionally live-relays the child's std-streams to `log.<level>` per-line. Suits both short-lived test-runners + long-lived daemons. `supervise_run_process()`, - Deterministic rc!=0: pass `check=False` to `trio` and do our OWN post-drain rc-check from the supervisor coro body AFTER `own_tn.__aexit__` — NOT inside the internal nursery, since that would race-cancel the still-draining relay reader and lose stderr lines. (Re)build + raise a BARE `subprocess.CalledProcessError`: `.stderr=` for programmatic callers + an `add_note()`'d `\|_.stderr:` block for human teardown logs. No nursery-eg-wrapped CPE to `collapse_eg` around. - Parent controlling-tty isolation: `stdin=DEVNULL` always, `stdout=DEVNULL` unless relayed/overridden (via `stdout=` kwarg w/ `_UNSET` sentinel so explicit `None` = inherit still works). Prevents a spawned program from clobbering the launching tty's scrollback w/ control-seqs. - Live per-line relay: `relay_stdout=True`/ `relay_stderr=True` → relayed to `log.<relay_level>` (default `'io'`, our custom level 21). Picked to sort just above stdlib `INFO`=20 so it shows at usual `info`/`devx` levels yet stays separately filterable; `runtime`=15 was REJECTED as a default since it'd be silently filtered at usual verbosity — footgun for daemon supervisors whose whole point is visibility. STREAMED, not buffered-until-exit. - Non-blocking `tn.start()` semantics: live `trio.Process` handed up via `task_status.started()` immediately (else `tn.start()` would block till child exit, losing the long-lived-daemon use case). Supervise/relay bg tasks run to completion in this coro. - `*run_process_kwargs` forwarded verbatim (env, shell, cwd, start_new_session, executable, ...); MANAGED keys (`stdin`/`stdout`/`stderr`/`check`) win on conflict. - Crash-handling layer intentionally NOT baked in — compose `maybe_open_crash_handler()` ON TOP at the call-site. `_relay_stream_lines()` helper, - Concurrent pipe-drain reader. MANDATORY whenever piping w/o `capture_` since nothing else drains the OS pipe — child blocks on `write()` once kernel buf (~64KiB) fills → deadlock. - Modes (combine freely): `emit`-only live relay, `accum`-only silent drain+capture (for the CPE note), or both. Per-line splitting handles cross-chunk residuals + flushes any trailing un-newline-term'd line at EOF. `_add_stderr_note()` helper, - Attaches an indented `\|_.stderr:` note to a CPE via `add_note()` for legible rc!=0 reporting at teardown. Tests (`tests/trionics/test_subproc.py`), - Hermetic `trio`-only (no actor-runtime). - `test_stdout_relayed_per_line`: per-line stdout relay. - `test_parent_tty_isolated`: child fd1 is OUR pipe (no `/dev/pts/*`), fd0 pinned to `/dev/null`. - `test_no_deadlock_on_big_unnewlined_output`: 200KiB no-newline output completes under `fail_after(2)` — exercises the concurrent drain (without it, the child blocks at ~64KiB). - `test_stderr_relay_and_cpe_rebuild`: rc!=0 w/ `relay_stderr=True` → bare `CalledProcessError` w/ the `.stderr` note + per-line live relay. - `test_nonrelay_cpe_note`: rc!=0 w/o relay → same deterministic post-drain CPE w/ `.stderr` note (silent drain+capture path). Re-export `supervise_run_process` from `tractor.trionics`. Prompt-IO: ai/prompt-io/claude/20260601T231429Z_0e3e008b_prompt_io.md (this patch was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code (cherry picked from commit `f595acc76c`) (cherry picked from commit `6df9ee11bc`)	2026-06-22 15:19:34 -04:00
Gud Boi	48c4e2415f	Use `is not None` check for peer-connect `event` Matches the explicit `dict.pop(uid, None)` contract one line above; same semantics as the prior truthy check. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code (cherry picked from commit `0e3e008b0c`) (cherry picked from commit `13ed668512`)	2026-06-22 15:19:34 -04:00
Gud Boi	023dbf89e4	Fix dropped `for/else` re-raise in masking CM `30e15925` ("Add `start_or_cancel()` to `trionics._taskc`") inserted `async def start_or_cancel()` — whose body opens its own col-4 `try:` — immediately before the trailing `else: raise`. Because the edit was a pure insertion (0 deletions), the same `else: raise` lines were silently REPARENTED: they used to be the `for exc_match in matching: ... else: raise` of `maybe_raise_from_masking_exc`, but now bind to `start_or_cancel`'s `try/except` where they're unreachable dead code. Net effect: `maybe_raise_from_masking_exc` lost the `for/else` re-raise of the un-masked exception, so a masked child cancellation gets swallowed instead of surfaced. - restore the `for/else: raise` to `maybe_raise_from_masking_exc` - drop the now-dead `else: raise` from `start_or_cancel` Surfaced as 2 deterministic failures in `test_sigint_closes_lifetime_stack[wait_for_ctx-bg_aio_task- send_SIGINT_to=child-*]` (the SIGINT-to-child "silent-abandon" regime). Bisected with `trio` held at `0.29.0`: clean at `9c36363b` (0/8), broken at `30e15925` (8/8), fixed (0/8). NOT a `trio` (0.29↔0.33 identical) nor logging-plugin regression. (this patch was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code (cherry picked from commit `325574cc07`) (cherry picked from commit `0b8033fdaa`)	2026-06-22 15:19:34 -04:00
Gud Boi	8952b39ee7	Add `start_or_cancel()` to `trionics._taskc` Wrapper around `trio.Nursery.start()` that DOESN'T mask out-of-band cancellation as a lossy startup failure. Picks the right re-raise: ambient `Cancelled` when present, the genuine startup-protocol `RuntimeError` otherwise. The problem, - `trio.Nursery.start()` raises a generic `RuntimeError("child exited without calling task_status.started()")` whenever the started task exits BEFORE calling `task_status.started()` — INCLUDING the common case where the child was cancelled out-of-band by an ancestor cancel-scope erroring/cancelling. - In that case the original `trio.Cancelled` is swallowed and the caller is left w/ an opaque, root-cause-detached `RuntimeError`. The fix, - Catch the "...started" RTE. - `await trio.lowlevel.checkpoint_if_cancelled()` — re-raises the in-flight `Cancelled` IFF we're under effective cancellation (ancestor-inclusive), carrying trio's auto-generated reason which points at the true root exc. - If we're NOT cancelled the `checkpoint_if_cancelled()` is a cheap no-op and we fall through to re-raise the genuine startup-protocol RTE. Re-export from `tractor.trionics` so callers don't have to reach into `_taskc`. (this patch was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code (cherry picked from commit `30e15925ba`) (cherry picked from commit `2b4589b1ee`)	2026-06-22 15:19:34 -04:00
Gud Boi	94a3413f5c	Add per-actor `setproctitle` via `devx._proctitle` New `tractor.devx._proctitle` mod sets each sub-actor's `argv[0]` (and kernel `comm`) to `tractor[<aid.reprol()>]` — e.g. `tractor[doggy@1027301b]` — so `ps`/`top`/`htop` and `acli.pytree`/reaper tooling can identify actors at a glance without parsing full cmdlines. Deats, - `set_actor_proctitle()` wraps the `setproctitle` pkg with `ImportError` guard; optional at runtime but listed in `pyproject.toml` so default installs benefit. - called early in `_child._actor_child_main()` after `Actor` construction, before `_trio_main()` entry. - tests in `tests/devx/test_proctitle.py`: format unit test, `/proc/{cmdline,comm}` integration test, negative detection test. Resolves #457 (this patch was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code (cherry picked from commit `d60245777e`)	2026-06-22 15:19:34 -04:00
Gud Boi	e4892a8e90	Split py-version-gated uv dependency-groups Reshuffle `pyproject.toml` deps into per-python-version `[tool.uv.dependency-groups]`: - `subints` group: `msgspec>=0.21.0`, py>=3.14 - `eventfd` group: `cffi>=1.17.1`, py>=3.13,<3.14 - `sync_pause` group: `greenback`, py>=3.13,<3.14 (was in `devx`; moved out bc no 3.14 yet) Bump top-level `msgspec>=0.20.0` too. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code (cherry picked from commit `34d9d482e4`) (factored: kept only the pyproject dep-group parts of "Raise `subint` floor to py3.14 and split dep-groups"; dropped tractor/spawn/_spawn.py + tractor/spawn/_subint.py)	2026-06-22 15:19:34 -04:00

Diff Content Not Available