diff --git a/freqtrade/data/dataprovider.py b/freqtrade/data/dataprovider.py index a392fb510..c05f5f564 100644 --- a/freqtrade/data/dataprovider.py +++ b/freqtrade/data/dataprovider.py @@ -446,10 +446,22 @@ class DataProvider: final_pairs = (pairlist + helping_pairs) if helping_pairs else pairlist # refresh latest ohlcv data self._exchange.refresh_latest_ohlcv(final_pairs) - # refresh latest trades data (if enabled) - self._exchange.refresh_latest_trades(final_pairs, - get_datahandler(self._config['datadir'], - data_format=self._config['dataformat_trades'])) + # refresh latest trades data + self.refresh_latest_trades(final_pairs) + + def refresh_latest_trades(self, + pairlist: ListPairsWithTimeframes) -> None: + """ + Refresh latest trades data (if enabled in config) + """ + + use_public_trades = self._config.get( + 'exchange', {}).get('use_public_trades', False) + if use_public_trades: + return self._exchange.refresh_latest_trades(pairlist, + get_datahandler(self._config['datadir'], + data_format=self._config['dataformat_trades'])) + return {} @property def available_pairs(self) -> ListPairsWithTimeframes: diff --git a/freqtrade/exchange/exchange.py b/freqtrade/exchange/exchange.py index 1f25a91a6..fad706d2e 100644 --- a/freqtrade/exchange/exchange.py +++ b/freqtrade/exchange/exchange.py @@ -2297,25 +2297,12 @@ class Exchange: now = timeframe_to_next_date(timeframe) return int((now - timedelta(seconds=move_to // 1000)).timestamp() * 1000) - def refresh_latest_trades(self, pair_list: ListPairsWithTimeframes , data_handler: Callable,# IDataHandler, *, cache: bool = True, ) -> Dict[PairWithTimeframe, DataFrame]: - use_public_trades = self._config.get( - 'exchange', {}).get('use_public_trades', False) - if use_public_trades: - return self._refresh_latest_trades(pair_list, data_handler, cache=cache) - return {} - - def _refresh_latest_trades(self, - pair_list: ListPairsWithTimeframes , - data_handler: Callable,# IDataHandler, - *, - cache: bool = True, - ) -> Dict[PairWithTimeframe, DataFrame]: """ Refresh in-memory TRADES asynchronously and set `_trades` with the result Loops asynchronously over pair_list and downloads all pairs async (semi-parallel).