update imports

This commit is contained in:
Matthias
2024-02-10 17:27:11 +01:00
parent cfcc8f9fde
commit 7ae69a9cde
2 changed files with 7 additions and 12 deletions

View File

@@ -15,8 +15,7 @@ from freqtrade.configuration import TimeRange
from freqtrade.constants import (FULL_DATAFRAME_THRESHOLD, Config, ListPairsWithTimeframes, from freqtrade.constants import (FULL_DATAFRAME_THRESHOLD, Config, ListPairsWithTimeframes,
PairWithTimeframe) PairWithTimeframe)
from freqtrade.data.converter import public_trades_to_dataframe from freqtrade.data.converter import public_trades_to_dataframe
from freqtrade.data.history import load_pair_history from freqtrade.data.history import get_datahandler, load_pair_history
from freqtrade.data.history.idatahandler import get_datahandler
from freqtrade.enums import CandleType, RPCMessageType, RunMode from freqtrade.enums import CandleType, RPCMessageType, RunMode
from freqtrade.exceptions import ExchangeError, OperationalException from freqtrade.exceptions import ExchangeError, OperationalException
from freqtrade.exchange import Exchange, timeframe_to_prev_date, timeframe_to_seconds from freqtrade.exchange import Exchange, timeframe_to_prev_date, timeframe_to_seconds
@@ -450,14 +449,12 @@ class DataProvider:
# refresh latest trades data # refresh latest trades data
self.refresh_latest_trades(pairlist) self.refresh_latest_trades(pairlist)
def refresh_latest_trades(self, def refresh_latest_trades(self, pairlist: ListPairsWithTimeframes) -> None:
pairlist: ListPairsWithTimeframes) -> None:
""" """
Refresh latest trades data (if enabled in config) Refresh latest trades data (if enabled in config)
""" """
use_public_trades = self._config.get( use_public_trades = self._config.get('exchange', {}).get('use_public_trades', False)
'exchange', {}).get('use_public_trades', False)
if use_public_trades: if use_public_trades:
datahandler = get_datahandler( datahandler = get_datahandler(
self._config['datadir'], data_format=self._config['dataformat_trades']) self._config['datadir'], data_format=self._config['dataformat_trades'])
@@ -533,8 +530,7 @@ class DataProvider:
data_handler = get_datahandler( data_handler = get_datahandler(
self._config['datadir'], data_format=self._config['dataformat_trades']) self._config['datadir'], data_format=self._config['dataformat_trades'])
ticks = data_handler.trades_load(pair) ticks = data_handler.trades_load(pair)
trades_df = public_trades_to_dataframe( trades_df = public_trades_to_dataframe(ticks.values.tolist(), pair=pair)
ticks.values.tolist(), pair=pair)
return trades_df return trades_df
else: else:

View File

@@ -10,7 +10,7 @@ from typing import Dict, List, Optional, Tuple, Union
from pandas import DataFrame from pandas import DataFrame
from freqtrade.constants import CUSTOM_TAG_MAX_LENGTH, Config, IntOrInf, ListPairsWithTimeframes from freqtrade.constants import CUSTOM_TAG_MAX_LENGTH, Config, IntOrInf, ListPairsWithTimeframes
from freqtrade.data import converter from freqtrade.data.converter import populate_dataframe_with_trades
from freqtrade.data.dataprovider import DataProvider from freqtrade.data.dataprovider import DataProvider
from freqtrade.enums import (CandleType, ExitCheckTuple, ExitType, MarketDirection, RunMode, from freqtrade.enums import (CandleType, ExitCheckTuple, ExitType, MarketDirection, RunMode,
SignalDirection, SignalTagType, SignalType, TradingMode) SignalDirection, SignalTagType, SignalType, TradingMode)
@@ -1410,15 +1410,14 @@ class IStrategy(ABC, HyperStrategyMixin):
self, dataframe, metadata, inf_data, populate_fn) self, dataframe, metadata, inf_data, populate_fn)
# TODO: extract this into a separate method e.g. if_enabled_populate_trades() # TODO: extract this into a separate method e.g. if_enabled_populate_trades()
use_public_trades = self.config.get( use_public_trades = self.config.get('exchange', {}).get('use_public_trades', False)
'exchange', {}).get('use_public_trades', False)
if use_public_trades: if use_public_trades:
trades = self.dp.trades(pair=metadata['pair'], copy=False) trades = self.dp.trades(pair=metadata['pair'], copy=False)
config = self.config config = self.config
config['timeframe'] = self.timeframe config['timeframe'] = self.timeframe
# TODO: slice trades to size of dataframe for faster backtesting # TODO: slice trades to size of dataframe for faster backtesting
dataframe = converter.populate_dataframe_with_trades( dataframe = populate_dataframe_with_trades(
config, config,
dataframe, dataframe,
trades, trades,