From 315990cd9028ec5644e1ba8d2de9c322dc94de67 Mon Sep 17 00:00:00 2001 From: jaxperro Date: Sat, 18 Jul 2026 09:06:41 -0400 Subject: [PATCH] =?UTF-8?q?recorder:=20reset=20freshness=20clock=20on=20re?= =?UTF-8?q?connect=20(insta-close=20loop=20bug)=20+=2045s=20stale=20guard?= =?UTF-8?q?=20=E2=80=94=20cuts=20per-flap=20tape=20loss?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-Authored-By: Claude Fable 5 --- recorder/recorder.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/recorder/recorder.py b/recorder/recorder.py index 0f0dfc1c..86bdb000 100644 --- a/recorder/recorder.py +++ b/recorder/recorder.py @@ -96,6 +96,8 @@ def main(): while True: def on_open(ws): ws.send(SUB) + tape.last_msg = time.time() # fresh clock — a stale one from the + # PREVIOUS connection would trip the guard instantly and loop log("rtds: connected — recording unfiltered trades") def ping(): @@ -105,8 +107,8 @@ def main(): ws.send('{"action":"ping"}') except Exception: break - if time.time() - tape.last_msg > 120: - log("rtds: silent 120s — forcing reconnect") + if time.time() - tape.last_msg > 45: + log("rtds: silent 45s — forcing reconnect") tape.gaps += 1 try: ws.close()