From ba7c8bb5a30b770f46c92af0b810d63e5489014e Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Thu, 5 Jan 2023 10:13:17 -0500 Subject: [PATCH] Don't receive sample-index msgs in feed layer --- piker/data/feed.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/piker/data/feed.py b/piker/data/feed.py index 0bd769de..4f2592ff 100644 --- a/piker/data/feed.py +++ b/piker/data/feed.py @@ -829,13 +829,19 @@ async def manage_history( # register 1s and 1m buffers with the global incrementer task async with open_sample_stream( - period_s=1, - cache_key=fqsn, + period_s=1., shms_by_period={ 1.: rt_shm.token, 60.: hist_shm.token, }, + + # NOTE: we want to only open a stream for doing broadcasts on + # backfill operations, not receive the sample index-stream + # (since there's no code in this data feed layer that needs to + # consume it). open_index_stream=True, + sub_for_broadcasts=False, + ) as sample_stream: log.info('Scanning for existing `marketstored`')