diff --git a/piker/fsp/_engine.py b/piker/fsp/_engine.py index 7d47e05f..b7806719 100644 --- a/piker/fsp/_engine.py +++ b/piker/fsp/_engine.py @@ -484,7 +484,8 @@ async def cascade( # open a data feed stream with requested broker feed: Feed async with data.feed.maybe_open_feed( - [fqme], + fqmes=[fqme], + loglevel=loglevel, # TODO throttle tick outputs from *this* daemon since # it'll emit tons of ticks due to the throttle only @@ -582,7 +583,8 @@ async def cascade( # on every step msg received from the global `samplerd` # service. async with open_sample_stream( - float(delay_s) + period_s=float(delay_s), + loglevel=loglevel, ) as istream: profiler(f'{func_name}: sample stream up')