mohammadian7/freqtrade
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: unwatch_ohlcv - improved error handling

Browse Source
This commit is contained in:
Matthias
2025-02-11 08:28:47 +01:00
parent 08e1a616a0
commit 44d798239d
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
freqtrade/exchange/exchange_ws.py
+4 -1
View File
@@ -84,6 +84,7 @@ class ExchangeWS:
Remove history for a pair/timeframe combination from ccxt cache Remove history for a pair/timeframe combination from ccxt cache
""" """
self._ccxt_object.ohlcvs.get(paircomb[0], {}).pop(paircomb[1], None) self._ccxt_object.ohlcvs.get(paircomb[0], {}).pop(paircomb[1], None)
self.klines_last_refresh.pop(paircomb, None)
@retrier(retries=3) @retrier(retries=3)
def ohlcvs(self, pair: str, timeframe: str) -> list[list]: def ohlcvs(self, pair: str, timeframe: str) -> list[list]:
@@ -140,10 +141,12 @@ class ExchangeWS:
async def _unwatch_ohlcv(self, pair: str, timeframe: str, candle_type: CandleType) -> None: async def _unwatch_ohlcv(self, pair: str, timeframe: str, candle_type: CandleType) -> None:
try: try:
await self.ccxt_object.un_watch_ohlcv_for_symbols([[pair, timeframe]]) await self._ccxt_object.un_watch_ohlcv_for_symbols([[pair, timeframe]])
except ccxt.NotSupported as e: except ccxt.NotSupported as e:
logger.debug("un_watch_ohlcv_for_symbols not supported: %s", e) logger.debug("un_watch_ohlcv_for_symbols not supported: %s", e)
pass pass
except Exception:
logger.exception("Exception in _unwatch_ohlcv")
def _continuous_stopped( def _continuous_stopped(
self, task: asyncio.Task, pair: str, timeframe: str, candle_type: CandleType self, task: asyncio.Task, pair: str, timeframe: str, candle_type: CandleType