diff --git a/piker/brokers/binance/feed.py b/piker/brokers/binance/feed.py index 02f4c77a..b1dcda85 100644 --- a/piker/brokers/binance/feed.py +++ b/piker/brokers/binance/feed.py @@ -275,12 +275,14 @@ 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]) + _time_step := (inow - times[-1]) > - timeframe + timeframe * 2 ): await tractor.pause()