From ed9c211b960ae5dc9e08ce8930badd95989be378 Mon Sep 17 00:00:00 2001 From: goodboy Date: Sat, 14 Feb 2026 16:57:36 -0500 Subject: [PATCH] Adjust binance stale-bar detection to 2x tolerance Change the stale-bar check in `.binance.feed` from `timeframe` to `timeframe * 2` tolerance to avoid false-positive pauses when bars are slightly delayed but still within acceptable bounds. Styling, - add walrus operator to capture `_time_step` for debugger inspection. - add comment explaining the debug purpose of this check. (this commit msg was generated in some part by [`claude-code`][claude-code-gh]) [claude-code-gh]: https://github.com/anthropics/claude-code --- piker/brokers/binance/feed.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) 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])