pikers
/
piker
4
1
Fork 0
Code Issues 10 Pull Requests 14 Packages Projects Releases Wiki Activity

Handle (far end forced) disconnects

its_happening
Tyler Goodlet 2020-08-09 00:01:40 -04:00
parent bdcf5f884b
commit a1e2730aa1
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
piker/brokers/kraken.py
View File

@ -9,6 +9,7 @@ import json
import time import time
import trio_websocket import trio_websocket
from trio_websocket._impl import ConnectionClosed, DisconnectionTimeout
import arrow import arrow
import asks import asks
import numpy as np import numpy as np
@ -247,7 +248,7 @@ async def stream_quotes(
}) })
yield asdict(ohlc) yield asdict(ohlc)
ohlc_last = ohlc ohlc_last = ohlc
except trio_websocket._impl.ConnectionClosed: except (ConnectionClosed, DisconnectionTimeout):
log.exception("Good job kraken...reconnecting") log.exception("Good job kraken...reconnecting")