CTYPTO/freqtrade
1
0
Fork 0
mirror of https://github.com/freqtrade/freqtrade.git synced 2025-12-15 20:31:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use proper typehint

Browse Source
This commit is contained in:
Matthias
2022-11-28 19:46:50 +01:00
parent aef0324aa7
commit 8a00bf3188
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
freqtrade/exchange/exchange.py
View File

@@ -2292,7 +2292,7 @@ class Exchange:
def _build_ohlcv_dl_jobs( def _build_ohlcv_dl_jobs(
self, pair_list: ListPairsWithTimeframes, since_ms: Optional[int], cache: bool 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 Build Coroutines to execute as part of refresh_latest_ohlcv
""" """

10
freqtrade/exchange/exchange_ws.py
View File

@@ -8,7 +8,7 @@ from typing import Dict, List, Set, Tuple
import ccxt import ccxt
from freqtrade.constants import Config from freqtrade.constants import Config, PairWithTimeframe
from freqtrade.enums.candletype import CandleType from freqtrade.enums.candletype import CandleType
from freqtrade.exchange.exchange import timeframe_to_seconds 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._thread = Thread(name="ccxt_ws", target=self.__start_forever)
self._background_tasks: Set[asyncio.Task] = set() self._background_tasks: Set[asyncio.Task] = set()
self._klines_watching: Set[Tuple[str, str, CandleType]] = set() self._klines_watching: Set[PairWithTimeframe] = set()
self._klines_scheduled: Set[Tuple[str, str, CandleType]] = set() self._klines_scheduled: Set[PairWithTimeframe] = set()
self.klines_last_refresh: Dict[Tuple[str, str, CandleType], float] = {} self.klines_last_refresh: Dict[PairWithTimeframe, float] = {}
self.klines_last_request: Dict[Tuple[str, str, CandleType], float] = {} self.klines_last_request: Dict[PairWithTimeframe, float] = {}
self._thread.start() self._thread.start()
def __start_forever(self) -> None: def __start_forever(self) -> None: