pikers
/
piker
3
0
Fork 0
Code Issues 4 Pull Requests 6 Packages Projects Releases Wiki Activity

wsbs: increase msg rx timeout to 16 secs

marketstore_disable_snappy
Tyler Goodlet 2023-05-09 14:39:45 -04:00
parent 05fb4a4014
commit 038b20d13a
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
piker/data/_web_bs.py
View File

@ -156,6 +156,10 @@ async def _reconnect_forever(
) -> None: ) -> None:
# TODO: can we just report "where" in the call stack
# the client code is using the ws stream?
# Maybe we can just drop this since it's already in the log msg
# orefix?
if fixture is not None: if fixture is not None:
src_mod: str = fixture.__module__ src_mod: str = fixture.__module__
else: else:
@ -295,8 +299,9 @@ async def open_autorecon_ws(
fixture: AsyncContextManager | None = None, fixture: AsyncContextManager | None = None,
# time in sec # time in sec between msgs received before
msg_recv_timeout: float = 3, # we presume connection might need a reset.
msg_recv_timeout: float = 16,
# count of the number of above timeouts before connection reset # count of the number of above timeouts before connection reset
reset_after: int = 3, reset_after: int = 3,