pikers
/
piker
3
0
Fork 0
Code Issues 4 Pull Requests 6 Packages Projects Releases Wiki Activity

Don't deliver shms from `start_backfill()`, they're not used

epoch_index_backup
Tyler Goodlet 2023-01-05 17:51:11 -05:00
parent 9a0605e405
commit 9c46b92ce7
1 changed files with 5 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
piker/data/feed.py
View File

@ -414,7 +414,9 @@ async def start_backfill(
and starts[next_start_dt] <= 6 and starts[next_start_dt] <= 6
): ):
start_dt = min(starts) start_dt = min(starts)
print(f"SKIPPING DUPLICATE FRAME @ {next_start_dt}") log.warning(
f"{bfqsn}: skipping duplicate frame @ {next_start_dt}"
)
starts[start_dt] += 1 starts[start_dt] += 1
continue continue
@ -616,10 +618,7 @@ async def tsdb_backfill(
# unblock the feed bus management task # unblock the feed bus management task
# assert len(shms[1].array) # assert len(shms[1].array)
task_status.started(( task_status.started()
shms[60],
shms[1],
))
async def back_load_from_tsdb( async def back_load_from_tsdb(
timeframe: int, timeframe: int,
@ -868,10 +867,7 @@ async def manage_history(
marketstore.open_storage_client(fqsn)as storage, marketstore.open_storage_client(fqsn)as storage,
): ):
# TODO: drop returning the output that we pass in? # TODO: drop returning the output that we pass in?
( await bus.nursery.start(
hist_shm,
rt_shm,
) = await bus.nursery.start(
tsdb_backfill, tsdb_backfill,
mod, mod,
marketstore, marketstore,