piker/piker/tsp
Gud Boi ce3d8e7a1e Only register shms w sampler when `feed_is_live`
Add timeout-gated wait for `feed_is_live: trio.Event` before passing shm
tokens to `open_sample_stream()`; skip registering shm-buffers with the
sampler if the feed doesn't "go live" within a new timeout.

The main motivation here is to avoid the sampler incrementing shm-array
bufs when the mkt-venue is closed so that a trailing "same price"
line/bars isn't updated/rendered in the chart's view when unnecessary.

Deats,
- add `wait_for_live_timeout: float = 0.5` param to `manage_history()`
- warn-log the fqme when timeout triggers
- add error log for invalid `frame_start_dt` comparisons to
  `maybe_fill_null_segments()`.

(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:08:35 -05:00
..
__init__.py Mv `markup_gaps()` to new `.tsp._annotate` mod 2026-02-22 22:08:34 -05:00
_anal.py Ignore single-zero-sample trace on no runtime.. 2026-02-22 22:08:35 -05:00
_annotate.py Use `get_fonts()`, add `show_txt` flag to gap annots 2026-02-22 22:08:35 -05:00
_dedupe_smart.py Add vlm-based "smart" OHLCV de-duping & bar validation 2026-02-22 22:08:34 -05:00
_history.py Only register shms w sampler when `feed_is_live` 2026-02-22 22:08:35 -05:00