Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

fix uncaught exchange rate manager errors when going offline

Browse source
This commit is contained in:
Jack Robison 2019-08-21 14:26:52 -04:00
parent 6b1f88df66
commit 48b4b97132
No known key found for this signature in database
GPG key ID: DF25C68FE0239BB2
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
lbry/lbry/extras/daemon/exchange_rate_manager.py
View file

@ -3,7 +3,8 @@ import time
import logging import logging
import json import json
from decimal import Decimal from decimal import Decimal
from typing import Optional
from aiohttp.client_exceptions import ClientError
from lbry.error import InvalidExchangeRateResponse, CurrencyConversionError from lbry.error import InvalidExchangeRateResponse, CurrencyConversionError
from lbry.utils import aiohttp_request from lbry.utils import aiohttp_request
@ -44,7 +45,7 @@ class MarketFeed:
self.params = params self.params = params
self.fee = fee self.fee = fee
self.rate = None self.rate = None
self._task: asyncio.Task = None self._task: Optional[asyncio.Task] = None
self._online = True self._online = True
def rate_is_initialized(self): def rate_is_initialized(self):
@ -80,7 +81,7 @@ class MarketFeed:
try: try:
response = await asyncio.wait_for(self._make_request(), self.REQUESTS_TIMEOUT) response = await asyncio.wait_for(self._make_request(), self.REQUESTS_TIMEOUT)
self._save_price(self._subtract_fee(self._handle_response(response))) self._save_price(self._subtract_fee(self._handle_response(response)))
except (asyncio.TimeoutError, InvalidExchangeRateResponse) as err: except (asyncio.TimeoutError, InvalidExchangeRateResponse, ClientError) as err:
self._on_error(err) self._on_error(err)
await asyncio.sleep(self.EXCHANGE_RATE_UPDATE_RATE_SEC) await asyncio.sleep(self.EXCHANGE_RATE_UPDATE_RATE_SEC)