No longer import ccxt.async_support

This commit is contained in:
Matthias
2023-08-10 06:46:24 +02:00
parent 55ed505f94
commit 67a6c11f6d

View File

@@ -14,7 +14,6 @@ from threading import Lock
from typing import Any, Coroutine, Dict, List, Literal, Optional, Tuple, Union from typing import Any, Coroutine, Dict, List, Literal, Optional, Tuple, Union
import ccxt import ccxt
import ccxt.async_support as ccxt_async
import ccxt.pro as ccxt_pro import ccxt.pro as ccxt_pro
from cachetools import TTLCache from cachetools import TTLCache
from ccxt import TICK_SIZE from ccxt import TICK_SIZE
@@ -152,7 +151,7 @@ class Exchange:
:return: None :return: None
""" """
self._api: ccxt.Exchange self._api: ccxt.Exchange
self._api_async: ccxt_async.Exchange = None self._api_async: ccxt_pro.Exchange = None
self._markets: Dict = {} self._markets: Dict = {}
self._trading_fees: Dict[str, Any] = {} self._trading_fees: Dict[str, Any] = {}
self._leverage_tiers: Dict[str, List[Dict]] = {} self._leverage_tiers: Dict[str, List[Dict]] = {}
@@ -232,7 +231,7 @@ class Exchange:
self._ws_async = self._init_ccxt(exchange_conf, False, ccxt_async_config) self._ws_async = self._init_ccxt(exchange_conf, False, ccxt_async_config)
self._has_watch_ohlcv = self.exchange_has("watchOHLCV") self._has_watch_ohlcv = self.exchange_has("watchOHLCV")
self._exchange_ws: Optional[ExchangeWS] = None self._exchange_ws: Optional[ExchangeWS] = None
if exchange_config.get("enable_ws", True) and self._has_watch_ohlcv: if exchange_conf.get("enable_ws", True) and self._has_watch_ohlcv:
self._exchange_ws = ExchangeWS(self._config, self._ws_async) self._exchange_ws = ExchangeWS(self._config, self._ws_async)
logger.info(f'Using Exchange "{self.name}"') logger.info(f'Using Exchange "{self.name}"')