From 8915f0c0c9806c4f737565182a9fa15819bebec0 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Sun, 1 May 2022 19:12:48 -0400 Subject: [PATCH] Terminate early on data unavailable errors --- piker/data/feed.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/piker/data/feed.py b/piker/data/feed.py index 88bf8810..eb57e71b 100644 --- a/piker/data/feed.py +++ b/piker/data/feed.py @@ -323,7 +323,7 @@ async def start_backfill( # broker is being a bish and we can't pull # any more.. log.warning('backend halted on data deliver !?!?') - # break + return input_end_dt, None to_push = diff_history( array, @@ -361,6 +361,11 @@ async def start_backfill( # Then iterate over the return values, as they become available # (i.e., not necessarily in the original order) async for input_end_dt, outcome in outcomes: + + # no data available case.. + if outcome is None: + break + try: out = outcome.unwrap() except Exception: