From d66fb49077b363c03c67a0700c2e23299cdeddf8 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Thu, 5 Jan 2023 17:51:11 -0500 Subject: [PATCH] Don't deliver shms from `start_backfill()`, they're not used --- piker/data/feed.py | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) diff --git a/piker/data/feed.py b/piker/data/feed.py index b1678d26..cc287d40 100644 --- a/piker/data/feed.py +++ b/piker/data/feed.py @@ -414,7 +414,9 @@ async def start_backfill( and starts[next_start_dt] <= 6 ): 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 continue @@ -616,10 +618,7 @@ async def tsdb_backfill( # unblock the feed bus management task # assert len(shms[1].array) - task_status.started(( - shms[60], - shms[1], - )) + task_status.started() async def back_load_from_tsdb( timeframe: int, @@ -868,10 +867,7 @@ async def manage_history( marketstore.open_storage_client(fqsn)as storage, ): # TODO: drop returning the output that we pass in? - ( - hist_shm, - rt_shm, - ) = await bus.nursery.start( + await bus.nursery.start( tsdb_backfill, mod, marketstore,