From 8a00bf3188ad9198d8be8551d5318e01aed69cef Mon Sep 17 00:00:00 2001 From: Matthias Date: Mon, 28 Nov 2022 19:46:50 +0100 Subject: [PATCH] Use proper typehint --- freqtrade/exchange/exchange.py | 2 +- freqtrade/exchange/exchange_ws.py | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/freqtrade/exchange/exchange.py b/freqtrade/exchange/exchange.py index 370225152..5b6b7a5d6 100644 --- a/freqtrade/exchange/exchange.py +++ b/freqtrade/exchange/exchange.py @@ -2292,7 +2292,7 @@ class Exchange: def _build_ohlcv_dl_jobs( self, pair_list: ListPairsWithTimeframes, since_ms: Optional[int], cache: bool - ) -> Tuple[List[Coroutine], List[Tuple[str, str, CandleType]]]: + ) -> Tuple[List[Coroutine], List[PairWithTimeframe]]: """ Build Coroutines to execute as part of refresh_latest_ohlcv """ diff --git a/freqtrade/exchange/exchange_ws.py b/freqtrade/exchange/exchange_ws.py index 1b685b116..6401c10b9 100644 --- a/freqtrade/exchange/exchange_ws.py +++ b/freqtrade/exchange/exchange_ws.py @@ -8,7 +8,7 @@ from typing import Dict, List, Set, Tuple import ccxt -from freqtrade.constants import Config +from freqtrade.constants import Config, PairWithTimeframe from freqtrade.enums.candletype import CandleType from freqtrade.exchange.exchange import timeframe_to_seconds @@ -23,10 +23,10 @@ class ExchangeWS(): self._thread = Thread(name="ccxt_ws", target=self.__start_forever) self._background_tasks: Set[asyncio.Task] = set() - self._klines_watching: Set[Tuple[str, str, CandleType]] = set() - self._klines_scheduled: Set[Tuple[str, str, CandleType]] = set() - self.klines_last_refresh: Dict[Tuple[str, str, CandleType], float] = {} - self.klines_last_request: Dict[Tuple[str, str, CandleType], float] = {} + self._klines_watching: Set[PairWithTimeframe] = set() + self._klines_scheduled: Set[PairWithTimeframe] = set() + self.klines_last_refresh: Dict[PairWithTimeframe, float] = {} + self.klines_last_request: Dict[PairWithTimeframe, float] = {} self._thread.start() def __start_forever(self) -> None: