piker

Author	SHA1	Message	Date
Gud Boi	89f9763744	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-22 22:10:39 -05:00
Gud Boi	abd9b18a25	.ui._editors: log multiline styling and re-leveling	2026-02-22 22:10:39 -05:00
Gud Boi	b8a7d58aed	.ui._lines: drop unused graphics-item import	2026-02-22 22:10:39 -05:00
Gud Boi	e433f24917	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-22 22:10:39 -05:00
Gud Boi	53b4775698	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-22 22:10:39 -05:00
Gud Boi	49f75ee1fe	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-22 22:10:39 -05:00
Gud Boi	cf70fb9f2e	Bump to latest official `pyqtgraph` release	2026-02-22 22:10:39 -05:00
Gud Boi	50011d33ef	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-22 22:09:54 -05:00
Gud Boi	903d39b615	Add `exchange_calendar` dep for venue-closure gap checkin	2026-02-22 22:09:54 -05:00
Gud Boi	3dad1c9835	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-22 22:09:54 -05:00
Gud Boi	b98c39598f	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-22 22:09:54 -05:00
Gud Boi	31a31fae0f	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-22 22:09:54 -05:00
Gud Boi	1dcbe7f22a	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-22 22:09:54 -05:00
Gud Boi	9c6f22c2c3	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-22 22:09:54 -05:00
Gud Boi	70b663992c	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-22 22:09:05 -05:00
Gud Boi	1827cdcf0f	Bump `platformdirs` version in lock file	2026-02-22 22:09:05 -05:00
Gud Boi	19d647f574	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-22 22:09:05 -05:00
Gud Boi	7c8baa8f4e	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-22 22:09:05 -05:00
Gud Boi	ed58ae139f	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-22 22:09:05 -05:00
Gud Boi	f2f696d341	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-22 22:09:05 -05:00
Gud Boi	e01ba6e31e	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-22 22:09:05 -05:00
Gud Boi	e08fb267f8	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-22 22:09:05 -05:00
Gud Boi	041f0d7e6f	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-22 22:09:05 -05:00
Gud Boi	b0ac3cd9b0	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-22 22:09:05 -05:00
Gud Boi	13edd7f709	.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-22 22:09:05 -05:00
Gud Boi	52c1c9c0fd	.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-22 22:09:05 -05:00
Gud Boi	e5b9fe97b4	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-22 22:09:05 -05:00
Gud Boi	76eefb97e2	.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-22 22:09:05 -05:00
Gud Boi	2e31ecbbe7	.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-22 22:09:05 -05:00
Gud Boi	81f770bb22	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-22 22:09:05 -05:00
Gud Boi	0dc6af3c1e	Bump to latest `xonsh` release	2026-02-22 22:09:05 -05:00
Gud Boi	f116d1a03b	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-22 22:09:05 -05:00

4 changed files with 68 additions and 18 deletions

									
										8

piker/brokers/_daemon.py

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

				    '''

				    from piker.service import maybe_spawn_daemon

				    # if (

				    #     loglevel != 'info'

				    # ):

				    #     await tractor.pause()

				    async with maybe_spawn_daemon(

				        service_name=f'brokerd.{brokername}',

				        f'brokerd.{brokername}',

				        service_task_target=spawn_brokerd,

				        spawn_args={

				            'brokername': brokername,

									
										9

piker/data/feed.py

										View File
									
				@ -819,6 +819,11 @@ 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={

				@ -885,6 +890,10 @@ 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,7 +99,6 @@ python-downloads = 'manual'

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

				default-groups = [

				  'uis',

				  'repl',

				]

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

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

				    "greenback >=1.1.1, <2.0.0",

				  # @goodboy's preferred console toolz

				  "xonsh>=0.22.2",

				  "xonsh",

				    "prompt-toolkit ==3.0.40",

				    "pyperclip>=1.9.0",

				@ -202,12 +201,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", git = "https://github.com/goodboy/tractor.git?branch=piker_pin" },
     { name = "tractor", editable = "../tractor" },
     { 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", specifier = ">=0.22.2" },
     { name = "xonsh", git = "https://github.com/xonsh/xonsh.git?branch=main" },
 ]
 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", specifier = ">=0.22.2" },
     { name = "xonsh", git = "https://github.com/xonsh/xonsh.git?branch=main" },
 ]
 testing = [{ name = "pytest" }]
 uis = [
 @ -1974,7 +1974,7 @@ wheels = [
 [[package]]
 name = "tractor"
 version = "0.1.0a6.dev0"
 source = { git = "https://github.com/goodboy/tractor.git?branch=piker_pin#36307c59175a1d04fecc77ef2c28f5c943b5f3d1" }
 source = { editable = "../tractor" }
 dependencies = [
     { name = "bidict" },
     { name = "cffi" },
 @ -1987,6 +1987,48 @@ 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"
 @ -2226,14 +2268,8 @@ wheels = [
 [[package]]
 name = "xonsh"
 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" },
 ]
 version = "0.22.3"
 source = { git = "https://github.com/xonsh/xonsh.git?branch=main#b446946fd94c3913e002318db1d1b41ee4fa1f9a" }
 [[package]]
 name = "yapic-json"

Compare commits

32 Commits

47cd48fea7 ... 89f9763744

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

32 Commits 47cd48fea7 ... 89f9763744

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

32 Commits

47cd48fea7 ... 89f9763744

8

piker/brokers/_daemon.py

View File

9

piker/data/feed.py

View File

9

pyproject.toml

View File

60

uv.lock

View File