From 43717c92d9e4a472286e241105b33c4c76ad5e52 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Wed, 16 Nov 2022 13:41:20 -0500 Subject: [PATCH] Type annot-declare fsp-engine data `Feed` --- piker/fsp/_engine.py | 2 ++ piker/ui/_fsp.py | 5 ++++- 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/piker/fsp/_engine.py b/piker/fsp/_engine.py index 5d389e29..c47455e3 100644 --- a/piker/fsp/_engine.py +++ b/piker/fsp/_engine.py @@ -36,6 +36,7 @@ from .. import data from ..data import attach_shm_array from ..data.feed import ( Flume, + Feed, ) from ..data._sharedmem import ShmArray from ..data._sampling import _default_delay_s @@ -302,6 +303,7 @@ async def cascade( raise ValueError(f'Unknown fsp target: {ns_path}') # open a data feed stream with requested broker + feed: Feed async with data.feed.maybe_open_feed( [fqsn], diff --git a/piker/ui/_fsp.py b/piker/ui/_fsp.py index dfbd8b9a..9e05f545 100644 --- a/piker/ui/_fsp.py +++ b/piker/ui/_fsp.py @@ -51,7 +51,10 @@ from ._forms import ( mk_form, open_form_input_handling, ) -from ..fsp._api import maybe_mk_fsp_shm, Fsp +from ..fsp._api import ( + maybe_mk_fsp_shm, + Fsp, +) from ..fsp import cascade from ..fsp._volume import ( # tina_vwap,