pikers
/
piker
4
1
Fork 0
Code Issues 10 Pull Requests 14 Packages Projects Releases Wiki Activity

Don't receive sample-index msgs in feed layer

epoch_index_backup
Tyler Goodlet 2023-01-05 10:13:17 -05:00
parent a4408fc740
commit ba7c8bb5a3
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
piker/data/feed.py
View File

@ -829,13 +829,19 @@ async def manage_history(
# register 1s and 1m buffers with the global incrementer task # register 1s and 1m buffers with the global incrementer task
async with open_sample_stream( async with open_sample_stream(
period_s=1, period_s=1.,
cache_key=fqsn,
shms_by_period={ shms_by_period={
1.: rt_shm.token, 1.: rt_shm.token,
60.: hist_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, open_index_stream=True,
sub_for_broadcasts=False,
) as sample_stream: ) as sample_stream:
log.info('Scanning for existing `marketstored`') log.info('Scanning for existing `marketstored`')