Compare commits

...

4 Commits

Author SHA1 Message Date
Tyler Goodlet 79eb8a1684 `.storage.__init__`: code styling updates 2026-01-07 14:33:11 -05:00
Tyler Goodlet a1b8554dfd `.tsp._history`: drop `feed_is_live` syncing, another seg flag
The `await feed_is_live.wait()` is more or less pointless and would only
cause slower startup afaig (as-far-as-i-grok) so i'm masking it here.
This also removes the final `strict_exception_groups=False` use from the
non-tests code base, flipping to the `tractor.trionics` collapser once
and for all!
2026-01-07 14:33:11 -05:00
Tyler Goodlet 2d79dce4a4 Woops, keep `np2pl` exposed from `.tsp` 2026-01-07 14:33:11 -05:00
Tyler Goodlet 3f674481d3 Factor to a new `.tsp._history` sub-mod
Cleaning out the `piker.tsp` pkg-mod to be only the (re)exports needed
for `._anal`/`._history` refs-use elsewhere!
2026-01-07 14:33:11 -05:00
3 changed files with 1501 additions and 1429 deletions

View File

@ -43,7 +43,6 @@ from typing import (
import numpy as np
from .. import config
from ..service import (
check_for_service,
@ -152,7 +151,10 @@ class StorageConnectionError(ConnectionError):
'''
def get_storagemod(name: str) -> ModuleType:
def get_storagemod(
name: str,
) -> ModuleType:
mod: ModuleType = import_module(
'.' + name,
'piker.storage',
@ -165,9 +167,12 @@ def get_storagemod(name: str) -> ModuleType:
@acm
async def open_storage_client(
backend: str | None = None,
backend: str|None = None,
) -> tuple[ModuleType, StorageClient]:
) -> tuple[
ModuleType,
StorageClient,
]:
'''
Load the ``StorageClient`` for named backend.
@ -267,7 +272,10 @@ async def open_tsdb_client(
from ..data.feed import maybe_open_feed
async with (
open_storage_client() as (_, storage),
open_storage_client() as (
_,
storage,
),
maybe_open_feed(
[fqme],
@ -275,7 +283,7 @@ async def open_tsdb_client(
) as feed,
):
profiler(f'opened feed for {fqme}')
profiler(f'opened feed for {fqme!r}')
# to_append = feed.hist_shm.array
# to_prepend = None

File diff suppressed because it is too large Load Diff

1480
piker/tsp/_history.py 100644

File diff suppressed because it is too large Load Diff