pikers
/
piker
3
0
Fork 0
Code Issues 2 Pull Requests 5 Packages Projects Releases Wiki Activity

Only log when the network first goes down

kivy_mainline_and_py3.8
Tyler Goodlet 2018-04-05 23:15:24 -04:00
parent bb44b9854b
commit 0cccdd01b5
1 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
piker/brokers/core.py
View File

@ -49,15 +49,21 @@ async def quote(brokermod: ModuleType, tickers: [str]) -> dict:
async def wait_for_network(get_quotes, sleep=1): async def wait_for_network(get_quotes, sleep=1):
"""Wait until the network comes back up. """Wait until the network comes back up.
""" """
down = False
while True: while True:
try: try:
with trio.move_on_after(1) as cancel_scope: with trio.move_on_after(1) as cancel_scope:
return await get_quotes() quotes = await get_quotes()
if down:
log.warn("Network is back up")
return quotes
if cancel_scope.cancelled_caught: if cancel_scope.cancelled_caught:
log.warn("Quote query timed out") log.warn("Quote query timed out")
continue continue
except socket.gaierror: except socket.gaierror:
log.warn(f"Network is down waiting for reestablishment...") if not down: # only report/log network down once
log.warn(f"Network is down waiting for re-establishment...")
down = True
await trio.sleep(sleep) await trio.sleep(sleep)