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,