From 5adb234a2471b850c2d44708dd7c0491f4f83f97 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 aa2a9a5a..c517777a 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`')