piker

Author	SHA1	Message	Date
Gud Boi	47cd48fea7	Pin `pg` at latest official `0.14.0` release Keep in masked GH sources lines for easy hackin against upstream `master` branch when needed as well!	2026-02-24 12:31:52 -05:00
Gud Boi	6b6eb82c21	.ui._editors: log multiline styling and re-leveling	2026-02-24 12:31:52 -05:00
Gud Boi	4d327d4c7a	.ui._lines: drop unused graphics-item import	2026-02-24 12:31:52 -05:00
Gud Boi	d36de5910b	Add batch-submit API for gap annotations Introduce `AnnotCtl.add_batch()` and `serve_rc_annots()` batch handler to submit 1000s of gaps in single IPC msg instead of per-annot round-trips. Server builds `GapAnnotations` from specs and handles vectorized timestamp-to-index lookups. Deats, - add `'cmd': 'batch'` handler in `serve_rc_annots()` - vectorized timestamp lookup via `np.searchsorted()` + masking - build `gap_specs: list[dict]` from rect+arrow specs client-side - create single `GapAnnotations` item for all gaps server-side - handle `GapAnnotations.reposition()` in redraw handler - add profiling to batch path for perf measurement - support optional individual arrows for A/B comparison Also, - refactor `markup_gaps()` to collect specs + single batch call - add `no_qt_updates()` context mgr for batch render ops - add profiling to annotation teardown path - add `GapAnnotations` case to `rm_annot()` match block (this patch was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-24 12:31:52 -05:00
Gud Boi	c299a08a06	Add a `GapAnnotations` path-renderer For a ~1000x perf gain says ol' claudy, our boi who wrote this entire patch! Bo Introduce `GapAnnotations` in `.ui._annotate` for batch-rendering gap rects/arrows instead of individual `QGraphicsItem` instances. Uses upstream's `pyqtgraph.Qt.internals.PrimitiveArray` for rects and a `QPainterPath` for arrows. This API-replicates our prior annotator's in view shape-graphics but now using (what we're dubbing) "single-array-multiple-graphics" tech much like our `.ui._curve` extensions to `pg` B) Impl deats, - batch draw ~1000 gaps in single paint call vs 1000 items - arrows render in scene coords to maintain pixel size on zoom - add vectorized timestamp-to-index lookup for repositioning - cache bounding rect, rebuild on `reposition()` calls - match `SelectRect` + `ArrowItem` visual style/colors - skip reposition when timeframe doesn't match gap's period Other, - fix typo in `LevelMarker` docstring: "graphich" -> "graphic" - reflow docstring in `qgo_draw_markers()` to 67 char limit (this patch was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-24 12:31:52 -05:00
Gud Boi	897db81305	Add info log for shm processing in `ldshm` CLI cmd Log shm file name and detected period before null segment processing to aid debugging. (this patch was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-24 12:31:52 -05:00
Gud Boi	56bc3596bb	Bump to latest official `pyqtgraph` release	2026-02-24 12:31:52 -05:00
Gud Boi	9a720f8e21	Merge pull request 'ib_venue_closures: gap detection for "legacy mkts"' (#71 ) Reviewed-on: https://www.pikers.dev/pikers/piker/pulls/71	2026-02-24 17:31:13 +00:00
Gud Boi	d17e6ab5d9	Add holiday-gap detection via `exchange_calendars` Integrate `exchange_calendars` lib to detect market holidays in gap-checking logic via new `.ib.venues.has_holiday()` helper! The `.ib.venues` impl deats, - add a new `has_holiday()` using `xcals.get_calendar()` and friends for sanity checking a venue's holiday closure-gaps. * final holiday detection-check is basically, `(cash_gap := (next_open - prev_close)) > period` - include `time_step_s` param to `is_venue_closure()` for boundary tolerance checks. * let's us expand closure-time checks to include `+/-time_step_s` "off-by-one-`timeframe`-sample" edge case ranges. - add real docstring to `has_weekend()`. In `.ib.api` refine usage for ^ changes, - move `is_venue_open()` call + tz-convert outside gap check - use a walrus to capture `has_closure_gap` from `is_venue_closure()` - add a `not has_closure_gap` condition to the mismatched-duration/short-frame warning block to avoid needless warns. - keep duration-based "short-frame" log as `.error()` but toss in a bp so (somone can) umask to figure out wtf is going on.. * we should never really hit this path unless there's a valid bug or data issue with IB/GFIS! * keep recursion path masked-out just leave a `breakpoint()` for now. Also some logger updates, - import `get_logger()` from top-level `piker.log` vs `.ib._util` which was always kinda wrong.. - change `NonShittyIB._logger` to use `__name__` vs literal. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 13:41:00 -05:00
Gud Boi	cd0c780d04	Add `exchange_calendar` dep for venue-closure gap checkin	2026-02-23 13:41:00 -05:00
Gud Boi	1417c49051	Adjust type annots in binance and IB symbol mods Namely, again switching `\|`-union syntax to rm adjacent white space. Also, flip to multiline style for threshold comparison in `.binance.feed` and change gap-check threshold to `timeframe` (vs a hardcoded `60`s) in the `get_ohlc()` closure. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 13:41:00 -05:00
Gud Boi	044afb0f6e	Use `.ib.venues.is_venue_open()` in `.feed` In `.ib.feed.stream_quotes()` specifically that is since time-range checking code was moved to the new sub-mod. Deats, - drop import of old `is_current_time_in_range()` from `._util` - change `get_bars()` sig: `end_dt`/`start_dt` to `datetime\|None` - comment-out `breakpoint()` in `open_history_client()` Styling, - add multiline style to conditionals and tuple unpacks - fix type annotation: `Contract\|None` vs `Contract \| None` - fix backticks in comment: `ib_insync` vs `ib_async` (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 13:41:00 -05:00
Gud Boi	c96ecdab75	Add venue-closure gap-detection in `.ib.api.Client.bars()` With all detection logic coming from our new `.ib.venues` helpers allowing use to verify IB's OHLC bars frames don't contain unexpected time-gaps. `Client.bars()` new checking deats, - add `is_venue_open()`, `has_weekend()`, `sesh_times()`, and `is_venue_closure()` checks when `last_dt < end_dt` - always calc gap-period in local tz via `ContractDetails.timeZoneId`. - log warnings on invalid non-closure gaps, debug on closures for now. - change recursion case to just `log.error()` + `breakpoint()`; we might end up tossing it since i don't think i could ever get it to be reliable.. * mask-out recursive `.bars()` call (likely unnecessary). - flip `start_dt`/`end_dt` param defaults to `None` vs epoch `str`. - update docstring to clarify no `start_dt` support by IB - add mod level `_iso8601_epoch_in_est` const to keep track of orig param default value. - add multiline style to return type-annot, type all `pendulum` objects. Also, - uppercase `Crypto.symbol` for PAXOS contracts in `.find_contracts()`, tho now we're getting a weird new API error i left in a todo-comment.. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 13:41:00 -05:00
Gud Boi	e1e59453a9	Mv `parse_trading_hours()` from `._util` to `.venues` It was an AI-model draft that we can prolly toss but figured might as well org it appropriately. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 13:41:00 -05:00
Gud Boi	d784af9df9	Add `.ib.venues` for mkt-venue-closure checkers Introduce set of helper-fns for detecting venue open/close status, session start/end times, and related time-gap detection using `pendulum`. Deats, - add `iter_sessions()` to yield `pendulum.Interval`s from a `ContractDetails` instance. - add `is_venue_open()` to check if active at a given time. - add `is_venue_closure()` to detect valid closure gaps. - add `sesh_times()` to extract weekday-agnostic open/close times. - add `has_weekend()` to check for Sat/Sun in interval. - move in lowlevel `is_current_time_in_range()` for checking a datetime within a `sesh: pendulum.Interval`. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 13:41:00 -05:00
Gud Boi	cabd3fde92	Merge pull request 'fix_tractor_logging: porting to latest `tractor.log` API(s)' (#76 ) Reviewed-on: #76	2026-02-23 18:40:35 +00:00
Gud Boi	2d0005ce48	Drop info-level `.pause()`-es used while devving	2026-02-23 13:26:46 -05:00
Gud Boi	d0add050b7	Better doc-strings n styling in `piker.cli` eps Add comprehensive docstrings to the top-level CLI endpoints and helpers, explaining the purpose and structure of each (sub)command. Deats, - add detailed docstring to `pikerd()` explaining its role as the root service-actor/daemon supervisor. - add docstring to `cli()` noting it's the root endpoint generally requiring a sub-cmd input. - add extensive docstring to `services()` explaining the daemon naming conventions and listing a few current/common service actors. - add docstring to `_load_clis()` explaining dynamic CLI loading. Stylin, - add multiline style to `and not maddrs` conditional in `load_trans_eps()`. - drop commented-out `--tsdb` and `--es` click options from `pikerd()`, they're more or less obsolete given `nativedb`. - add type annots where obviously handy. - add TODO comment about UDS support in `services()`. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	709bc8a5be	Bump `platformdirs` version in lock file	2026-02-23 12:22:48 -05:00
Gud Boi	c7979d0100	Enable console logging in `.accounting` on import Enable `get_console_log()` at `.accounting.__init__` import-time to ensure console output is available whenever the subsystem is used by `.clearing` or other code. Deats, - uncomment and complete `get_console_log()` call in `.accounting.__init__` with default `level='warning'` and `name=__name__`. - update comment explaining rationale: better to enable on import since namely used by `.clearing` subsystem. Also, - change `piker.calc` import to relative `.calc` in `.accounting.__init__`. - drop unused `get_console_log` import from `.accounting._pos`. - add `log = get_logger(name=__name__)` to `.accounting.cli`. - change `get_logger(loglevel)` -> `get_console_log()` in `.accounting.cli.sync()` with proper kwargs. - add `get_console_log` import to `.accounting.cli`. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	9a97c477e2	Use `name=__name__` for logs throughout `.service` Change all `.service` sub-modules to use `get_logger(name=__name__)` for per-submod instances vs a shared `._util.log`. Deats, - import `get_logger()` and `get_console_log()` from top-level `piker.log` instead of `._util` for all. - drop `log` and `get_console_log()` partial from `._util`. - add `name=subsys` kwarg to `get_console_log()` call in `_actor_runtime.maybe_open_pikerd()`. - add `name='piker.service'` to `get_console_log()` in `_ahab.open_ahabd()`. - change default `loglevel` from `None` to `'cancel'` in `_ahab.open_ahabd()`. - add sanity check: `assert log.name == 'piker.service'` in `_daemon.maybe_spawn_daemon()`. - change `print()` -> `log.info()` in `_registry.find_service()`. - drop stray `from piker.service._util import log` import in `brokers._daemon.spawn_brokerd()`. Styling/cleanups, - drop blank lines from various fn sigs. - do more sin-ws union type annots. - add more multiline style to `or` expressions in `_actor_runtime` and `_registry`. - update `._util` docstring with TODO about `import`-time console log setup. - add TODO comments in `_registry` about UDS registry support. - use `.aid.uid` from actor in `_registry.open_registry()`. - add intermediate var `reg_addrs` in `_registry.open_registry()` (bc i was tracing rtvs value issues in `tractor`). - add `pformat` import to `.elastic` (code path is currently not used but figured might as well appease the linter..) (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	2516d97fe4	Pass `loglevel` down through `.ui` graphics tasks Add `loglevel` propagation to UI graphics tasks and sampler stream opens to enable proper console logging in chart update loops. This ensures the graphics and FSP subsystems receive the same loglevel as their parent and/or sibling UI-actor tasks. Deats, - add `loglevel` param to `graphics_update_loop()` and `increment_history_view()` with default `'warning'`. - pass `loglevel` to `open_sample_stream()` calls in both fns. - use `partial()` to pass `loglevel` through to `nurse.start_soon()` calls in `display_symbol_data()` and `graphics_update_loop()`. Also logging, doc-strs, and code-style tweaks, - change `print()` -> `log.debug()` for hidden-chart and interaction-pause msgs in graphics loop. - change `log.info()` -> `log.debug()` for resize events in `GodWidget` and `MainWindow`. - add multiline style to resize log msg in `GodWidget`. - add docstring to `MainWindow.on_focus_change()`. - moar union type annot adjustments. - switch to explicit kwarg `period_s=` for `open_sample_stream()` in `increment_history_view()`. - multiline style for `names` list in `open_fsp_actor_cluster()`. - change `count=2` -> `count=len(names)` in `open_fsp_actor_cluster()`. - add TODO about using `.experimental` for cluster import (once that get's patched into upstream `tractor`). - multiline style for `or` in `FspAdmin.start_engine_task()`. - comment-out unused `brokernames` in `ui.cli.chart()`. - add commented breakpoint in `ui.cli.chart()`. - fix docstring style in `OrderMode.on_submit()`. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	5bfc9d46e1	Pass `loglevel` to `cascade()` feed/sampler opens Add `loglevel` param to both `maybe_open_feed()` and `open_sample_stream()` calls in FSP engine's `cascade()` task to ensure proper console log setup in downstream sampling tasks. Deats, - pass `loglevel=loglevel` to `maybe_open_feed()` call. - pass `loglevel=loglevel` to `open_sample_stream()` call. Also, - switch to explicit kwargs: `fqmes=[fqme]` and `period_s=` for clarity and consistency with other callsites. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	aa403bd390	Pass `loglevel` down through `.data` callstack Add `loglevel` param propagation across the data feed and sampling subsystems to enable proper console log setup in downstream (distibuted) subactor tasks. This ensures sampler and history-mgmt tasks receive the same loglevel as their parent `.data.feed` tasks. Deats, - add `loglevel: str\|None` param to `register_with_sampler()`, `maybe_open_samplerd()`, and `open_sample_stream()`. - pass `loglevel` through to `get_console_log()` in `register_with_sampler()` with fallback to actor `loglevel`. - use `partial()` in `allocate_persistent_feed()` to pass `loglevel` to `manage_history()` at task-start. - add `loglevel` param to `manage_history()` with default `'warning'` and pass through to `open_sample_stream()` from there. - capture `loglevel` var in `brokers.cli.search()` and pass to `symbol_search()` call. Also, - drop blank lines in fn sigs for consistency with piker style. - add debug bp in `open_feed()` when `loglevel != 'info'`. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	c1530c7a37	Enable console via `.clearing._ems.open_brokerd_dialog()` Enable console logs for both `.clearing` and `.accounting` in `open_brokerd_dialog()` and pass `loglevel` to all broker-backend trade-dialog endpoints. This ensures all `open_trade_dialog()` will receive the same level passed to the EMS, including the paper engine. Deats, - add `loglevel` param to `mk_paper_ep()` closure. - pass `loglevel=loglevel` to all trade endpoint `open_context()` calls and `mk_paper_ep()` invocations. - change default `loglevel` in `open_ems()` from `'error'` to `'warning'`. - add `get_console_log()` calls for `'clearing'` and `'piker.accounting'` at top of `open_brokerd_dialog()` to ensure those dependent subsystems are console enabled given they're namely used by the `brokerd` trade-dialog ep tasks. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	50ffc1095b	Use `__name__` for loggers across most sub-mods Change most sub-modules to use `get_logger(name=__name__)` for per-leaf-module `log` instances vs previous subpkg-level/shared refs. Primary changes, - import `get_[console_]logger()` from top-level `piker.log` across leaf mods. - change any `<subsys>._util.log` logger-instances as well (though this approach should no longer be used since it masks the endpoint module's emissions. Also, - add a defaulted `loglevel: str` param to all `open_trade_dialog()` endpoints, anticipating it being passed in by `.clearing`-engine. - call `get_console_log(level=loglevel, name=__name__)` in each trade dialog ep to enable per-`brokerd`-backend console writing. - drop `get_logger` from `.brokers.__all__` exports - fix type annotations: `str\|None` vs `str \| None` - add TODOs for, * comments in `._util` about multi-subsys logging * `.accounting.__init__` about console log setup (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	437d87ab5f	Use `__name__` for loggers across `.ib` sub-mods Change all `.ib` sub-modules to use `get_logger(name=__name__)` for per-module logger instances vs shared `._util.log`. Deats, - change `._util` to use `__name__` vs literal string. - change `.broker`, `.feed`, `.ledger`, `.symbols` to import `get_logger()` from top-level `.log` and call with `__name__`. - drop `log` imports from `._util` in all affected mods. Also, - drop trailing comma in `.cli.services()` conditional for `loglevel` passthrough -> fixes an actual kwargs bug!! (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	0087cc8876	.data.feed: move `Flume` import to avoid cycle Move `Flume` to `TYPE_CHECKING` and add runtime imports in `allocate_persistent_feed()` + `open_feed()` to avoid cycle with `.flows` mod. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	034fa19372	.fsp._engine: enable console logging in `cascade()` Add console log setup with module name + multiline style for desync warning msg. Also, - fix import: `Flume` from `.data.flows` vs `.data.feed` - move `Feed` to `TYPE_CHECKING` block - add TODO comment about `tractor._state` dict issue (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	0f0bbd1cda	Add order-cancel debugging and multiline kbd logs Add verbose logging + error handling for order cancellation hotkey path and multiline style for view-mode kb msgs. Deats, - add `Cursor.is_hovered()` to check hover state - log warnings when no orders cancelled via <c> hotkey - add try-except around `.cancel_orders_under_cursor()` - log `cur._hovered` state in `.ui._lines` hover handlers - change `Dialog.cancel_orders()` to return `list[Dialog]` - fix import: `Flume` from `.data.flows` vs `.data.feed` - comment-out multi-status msgs in order submit/cancel Also, - convert all multiline kbd `if` conditionals to use `and` on separate lines for consistency - move `import tractor` to top of `._interaction` - change `print()` to `log.debug()` in `LevelLine` - fix type annotation spacing: `Callable\|None` vs `Callable \| None` (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	3b6484c340	.ui._app: enable console logging in `_async_main()` Now we're actualy emitting colored-logs (again?), not sure how this got borked but maybe it's due to `tractor.log`'s new changes? (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	6d896eeed2	.brokers._daemon: enable `tractor` log in `brokerd` Also, - capture `Actor.loglevel` in `tll` var for reuse (when `loglevel` is null) and pass `bool`-ed as new `with_tractor_log`-flag. - add `with_tractor_log=bool(tll)` to `.get_console_log()` - add assertion check for logger name. - comment-out `tractor.trionics.collapse_eg()` context for now, pretty sure we don't need it and it just ends up adding extra logging overhead for no good reason (warnings on various `trio` internal cancelled-maskings, etc). - change type annotation: `str\|None` vs `str \| None`. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	bdedb16cdc	Auto-enable `tractor` logging when runtime active Check for active `tractor` runtime via `.current_actor()` and use its `.loglevel` to auto-enable `tractor`'s internal console logging when `with_tractor_log` is not explicitly set. Deats, - add `tll` (tractor log level) var to capture level - check `with_tractor_log is not False` first - fallback to `maybe_actor.loglevel` if runtime exists - only call `tractor.log.get_console_log()` if `tll` set - add TODO comment about "log-spec" style config support (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code	2026-02-23 12:22:48 -05:00
Gud Boi	d8bfdd775c	Adjust `tractor.log` API compat Update logging helpers to use new `tractor.log` API with `pkg_name=` kwarg and add optional `tractor` "root logger" enabling. Deats, - change `piker.log.get_logger()` to use `pkg_name=` vs `_root_name=`. - add `**tractor_log_kwargs` passthrough to both wrapper fns. - add `with_tractor_log: bool` toggle to `.get_console_log()`. - strip `'piker.'` prefix from logger names when present to avoid newly added `tractor.get_logger()` warnings. Surroundingly, - add `subsys` import to `.clearing._ems` for log name - update all `get_console_log()` calls to use `level=` kwarg - add assertion checks for logger names in `_setup_persistent_emsd()` Additionally,, - fix all type annotations: `str\|None` vs `str \| None`. - add multiline style to conditional in `.cli.services()`. - drop unused `Optional` import from `._actor_runtime`. - drop a few "blank lines" in various function sigs. Warning: this patch will require an equivalent dev-commit at the time of writing in `tractor` itself, for now the `piker_pin` branch should be sufficient to avoid breakage 🙏! (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code k	2026-02-23 12:22:48 -05:00
Gud Boi	73369fb1ef	Merge pull request 'hist_backfill_fixes: working-around (some) conc issues in the tsdb backfiller' (#62 ) Reviewed-on: #62 Reviewed-by: momo <dilarayalniz1@gmail.com>	2026-02-23 17:22:24 +00:00
Gud Boi	8dd969e85f	Pin to min `xonsh` release for @goodboy needs	2026-02-23 12:17:04 -05:00
Gud Boi	90fce9fcd4	Woops, use `piker_pin` from GH for `tractor` Also, install the `'repl'` deps-group by default to ensure we get the extras required by `tractor` for non-`trio` task debug REPLin.. Bump lock file to match.	2026-02-22 23:37:32 -05:00

4 changed files with 18 additions and 68 deletions

									
										8

piker/brokers/_daemon.py

										View File
									
				@ -272,14 +272,8 @@ async def maybe_spawn_brokerd(

				    '''

				    from piker.service import maybe_spawn_daemon

				    # if (

				    #     loglevel != 'info'

				    # ):

				    #     await tractor.pause()

				    async with maybe_spawn_daemon(

				        f'brokerd.{brokername}',

				        service_name=f'brokerd.{brokername}',

				        service_task_target=spawn_brokerd,

				        spawn_args={

				            'brokername': brokername,

									
										9

piker/data/feed.py

										View File
									
				@ -819,11 +819,6 @@ async def maybe_open_feed(

				    '''

				    fqme = fqmes[0]

				    # if (

				    #     loglevel != 'info'

				    # ):

				    #     await tractor.pause()

				    async with trionics.maybe_open_context(

				        acm_func=open_feed,

				        kwargs={

				@ -890,10 +885,6 @@ async def open_feed(

				        providers.setdefault(mod, []).append(bs_fqme)

				        feed.mods[mod.name] = mod

				    if (

				        loglevel != 'info'

				    ):

				        await tractor.pause()

				    # one actor per brokerd for now

				    brokerd_ctxs = []

				    for brokermod, bfqmes in providers.items():

									
										9

pyproject.toml

										View File
									
				@ -99,6 +99,7 @@ python-downloads = 'manual'

				# https://docs.astral.sh/uv/concepts/projects/dependencies/#default-groups

				default-groups = [

				  'uis',

				  'repl',

				]

				# ------ tool.uv ------

				@ -130,7 +131,7 @@ repl = [

				    "greenback >=1.1.1, <2.0.0",

				  # @goodboy's preferred console toolz

				  "xonsh",

				  "xonsh>=0.22.2",

				    "prompt-toolkit ==3.0.40",

				    "pyperclip>=1.9.0",

				@ -201,12 +202,12 @@ pyvnc = { git = "https://github.com/regulad/pyvnc.git" }

				# to get fancy next-cmd/suggestion feats prior to 0.22.2 B)

				# https://github.com/xonsh/xonsh/pull/6037

				# https://github.com/xonsh/xonsh/pull/6048

				xonsh = { git = 'https://github.com/xonsh/xonsh.git', branch = 'main' }

				# xonsh = { git = 'https://github.com/xonsh/xonsh.git', branch = 'main' }

				# XXX since, we're like, always hacking new shite all-the-time. Bp

				# tractor = { git = "https://github.com/goodboy/tractor.git", branch ="piker_pin" }

				tractor = { git = "https://github.com/goodboy/tractor.git", branch ="piker_pin" }

				# tractor = { git = "https://pikers.dev/goodboy/tractor", branch = "piker_pin" }

				# tractor = { git = "https://pikers.dev/goodboy/tractor", branch = "main" }

				# ------ goodboy ------

				# hackin dev-envs, usually there's something new he's hackin in..

				tractor = { path = "../tractor", editable = true }

				# tractor = { path = "../tractor", editable = true }

60

uv.lock

View File

 @ -1197,7 +1197,7 @@ requires-dist = [
     { name = "tomli", specifier = ">=2.0.1,<3.0.0" },
     { name = "tomli-w", specifier = ">=1.0.0,<2.0.0" },
     { name = "tomlkit", git = "https://github.com/pikers/tomlkit.git?branch=piker_pin" },
     { name = "tractor", editable = "../tractor" },
     { name = "tractor", git = "https://github.com/goodboy/tractor.git?branch=piker_pin" },
     { name = "trio", specifier = ">=0.27" },
     { name = "trio-typing", specifier = ">=0.10.0" },
     { name = "trio-util", specifier = ">=0.7.0,<0.8.0" },
 @ -1222,7 +1222,7 @@ dev = [
     { name = "pytest" },
     { name = "qdarkstyle", specifier = ">=3.0.2,<4.0.0" },
     { name = "rapidfuzz", specifier = ">=3.2.0,<4.0.0" },
     { name = "xonsh", git = "https://github.com/xonsh/xonsh.git?branch=main" },
     { name = "xonsh", specifier = ">=0.22.2" },
 ]
 lint = [{ name = "ruff", specifier = ">=0.9.6" }]
 repl = [
 @ -1231,7 +1231,7 @@ repl = [
     { name = "pexpect", specifier = ">=4.9.0" },
     { name = "prompt-toolkit", specifier = "==3.0.40" },
     { name = "pyperclip", specifier = ">=1.9.0" },
     { name = "xonsh", git = "https://github.com/xonsh/xonsh.git?branch=main" },
     { name = "xonsh", specifier = ">=0.22.2" },
 ]
 testing = [{ name = "pytest" }]
 uis = [
 @ -1974,7 +1974,7 @@ wheels = [
 [[package]]
 name = "tractor"
 version = "0.1.0a6.dev0"
 source = { editable = "../tractor" }
 source = { git = "https://github.com/goodboy/tractor.git?branch=piker_pin#36307c59175a1d04fecc77ef2c28f5c943b5f3d1" }
 dependencies = [
     { name = "bidict" },
     { name = "cffi" },
 @ -1987,48 +1987,6 @@ dependencies = [
     { name = "wrapt" },
 ]
 [package.metadata]
 requires-dist = [
     { name = "bidict", specifier = ">=0.23.1" },
     { name = "cffi", specifier = ">=1.17.1" },
     { name = "colorlog", specifier = ">=6.8.2,<7" },
     { name = "msgspec", specifier = ">=0.19.0" },
     { name = "pdbp", specifier = ">=1.8.2,<2" },
     { name = "platformdirs", specifier = ">=4.4.0" },
     { name = "tricycle", specifier = ">=0.4.1,<0.5" },
     { name = "trio", specifier = ">0.27" },
     { name = "wrapt", specifier = ">=1.16.0,<2" },
 ]
 [package.metadata.requires-dev]
 dev = [
     { name = "greenback", specifier = ">=1.2.1,<2" },
     { name = "pexpect", specifier = ">=4.9.0,<5" },
     { name = "prompt-toolkit", specifier = ">=3.0.50" },
     { name = "psutil", specifier = ">=7.0.0" },
     { name = "pyperclip", specifier = ">=1.9.0" },
     { name = "pytest", specifier = ">=8.3.5" },
     { name = "stackscope", specifier = ">=0.2.2,<0.3" },
     { name = "typing-extensions", specifier = ">=4.14.1" },
     { name = "xonsh", specifier = ">=0.22.2" },
 ]
 devx = [
     { name = "greenback", specifier = ">=1.2.1,<2" },
     { name = "stackscope", specifier = ">=0.2.2,<0.3" },
     { name = "typing-extensions", specifier = ">=4.14.1" },
 ]
 lint = [{ name = "ruff", specifier = ">=0.9.6" }]
 repl = [
     { name = "prompt-toolkit", specifier = ">=3.0.50" },
     { name = "psutil", specifier = ">=7.0.0" },
     { name = "pyperclip", specifier = ">=1.9.0" },
     { name = "xonsh", specifier = ">=0.22.2" },
 ]
 testing = [
     { name = "pexpect", specifier = ">=4.9.0,<5" },
     { name = "pytest", specifier = ">=8.3.5" },
 ]
 [[package]]
 name = "tricycle"
 version = "0.4.1"
 @ -2268,8 +2226,14 @@ wheels = [
 [[package]]
 name = "xonsh"
 version = "0.22.3"
 source = { git = "https://github.com/xonsh/xonsh.git?branch=main#b446946fd94c3913e002318db1d1b41ee4fa1f9a" }
 version = "0.22.4"
 source = { registry = "https://pypi.org/simple" }
 sdist = { url = "https://files.pythonhosted.org/packages/48/df/1fc9ed62b3d7c14612e1713e9eb7bd41d54f6ad1028a8fbb6b7cddebc345/xonsh-0.22.4.tar.gz", hash = "sha256:6be346563fec2db75778ba5d2caee155525e634e99d9cc8cc347626025c0b3fa", size = 826665, upload-time = "2026-02-17T07:53:39.424Z" }
 wheels = [
     { url = "https://files.pythonhosted.org/packages/2e/00/7cbc0c1fb64365a0a317c54ce3a151c9644eea5a509d9cbaae61c9fd1426/xonsh-0.22.4-py311-none-any.whl", hash = "sha256:38b29b29fa85aa756462d9d9bbcaa1d85478c2108da3de6cc590a69a4bcd1a01", size = 654375, upload-time = "2026-02-17T07:53:37.702Z" },
     { url = "https://files.pythonhosted.org/packages/2e/c2/3dd498dc28d8f89cdd52e39950c5e591499ae423f61694c0bb4d03ed1d82/xonsh-0.22.4-py312-none-any.whl", hash = "sha256:4e538fac9f4c3d866ddbdeca068f0c0515469c997ed58d3bfee963878c6df5a5", size = 654300, upload-time = "2026-02-17T07:53:35.813Z" },
     { url = "https://files.pythonhosted.org/packages/82/7d/1f9c7147518e9f03f6ce081b5bfc4f1aceb6ec5caba849024d005e41d3be/xonsh-0.22.4-py313-none-any.whl", hash = "sha256:cc5fabf0ad0c56a2a11bed1e6a43c4ec6416a5b30f24f126b8e768547c3793e2", size = 654818, upload-time = "2026-02-17T07:53:33.477Z" },
 ]
 [[package]]
 name = "yapic-json"

Compare commits

37 Commits

89f9763744 ... 47cd48fea7

8

piker/brokers/_daemon.py

View File

9

piker/data/feed.py

View File

9

pyproject.toml

View File

60

uv.lock

View File

Compare commits

37 Commits 89f9763744 ... 47cd48fea7

8 piker/brokers/_daemon.py Unescape Escape View File

9 piker/data/feed.py Unescape Escape View File

9 pyproject.toml Unescape Escape View File

60 uv.lock Unescape Escape View File

37 Commits

89f9763744 ... 47cd48fea7

8

piker/brokers/_daemon.py

View File

9

piker/data/feed.py

View File

9

pyproject.toml

View File

60

uv.lock

View File