diff --git a/piker/brokers/binance/feed.py b/piker/brokers/binance/feed.py index 53a5073d..ff5f6ec0 100644 --- a/piker/brokers/binance/feed.py +++ b/piker/brokers/binance/feed.py @@ -275,9 +275,15 @@ async def open_history_client( f'{times}' ) + # XXX, debug any case where the latest 1m bar we get is + # already another "sample's-step-old".. if end_dt is None: inow: int = round(time.time()) - if (inow - times[-1]) > 60: + if ( + _time_step := (inow - times[-1]) + > + timeframe * 2 + ): await tractor.pause() start_dt = from_timestamp(times[0])