Reconnect slow binance conns instead of error

2021-05-27 17:30:30 -04:00 · 2021-05-27 17:30:30 -04:00 · 19711bf024
parent 1a7b06c147
commit 19711bf024
1 changed files with 2 additions and 1 deletions
--- a/piker/brokers/binance.py
+++ b/piker/brokers/binance.py
@ -308,7 +308,8 @@ async def stream_messages(ws):

            timeouts += 1
            if timeouts > 10:
-                raise trio.TooSlowError("binance feed seems down?")
+                log.error("binance feed seems down and slow af? rebooting...")
+                await ws._connect()

            continue