Type annot-declare fsp-engine data `Feed`

samplerd_service
Tyler Goodlet 2022-11-16 13:41:20 -05:00
parent f370685c62
commit 43717c92d9
2 changed files with 6 additions and 1 deletions

View File

@ -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],

View File

@ -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,