mohammadian7/freqtrade
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Minor adjustments to conversions

Browse Source
This commit is contained in:
Matthias
2023-09-25 19:45:03 +02:00
parent 83b37e2f78
commit a7d90e2a25
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
freqtrade/data/converter/trade_converter_kraken.py
+3 -4
View File
@@ -1,12 +1,12 @@
import logging import logging
from pathlib import Path from pathlib import Path
import numpy as np
import pandas as pd import pandas as pd
from freqtrade.constants import DATETIME_PRINT_FORMAT, DEFAULT_TRADES_COLUMNS, Config from freqtrade.constants import DATETIME_PRINT_FORMAT, DEFAULT_TRADES_COLUMNS, Config
from freqtrade.data.converter.trade_converter import (trades_convert_types, from freqtrade.data.converter.trade_converter import (trades_convert_types,
trades_df_remove_duplicates) trades_df_remove_duplicates)
from freqtrade.data.history.idatahandler import get_datahandler
from freqtrade.resolvers import ExchangeResolver from freqtrade.resolvers import ExchangeResolver
@@ -22,7 +22,6 @@ def import_kraken_trades_from_csv(config: Config, convert_to: str):
if config['exchange']['name'] != 'kraken': if config['exchange']['name'] != 'kraken':
raise ValueError('This function is only for kraken exchange') raise ValueError('This function is only for kraken exchange')
from freqtrade.data.history.idatahandler import get_datahandler
datadir: Path = config['datadir'] datadir: Path = config['datadir']
data_handler = get_datahandler(datadir, data_format=convert_to) data_handler = get_datahandler(datadir, data_format=convert_to)
@@ -36,7 +35,7 @@ def import_kraken_trades_from_csv(config: Config, convert_to: str):
(m['symbol'], m['altname']) for m in exchange.markets.values() (m['symbol'], m['altname']) for m in exchange.markets.values()
if m.get('altname') in data_symbols if m.get('altname') in data_symbols
} }
logger.info(f"Found csv files for {', '.join(data_symbols)}") logger.info(f"Found csv files for {', '.join(data_symbols)}.")
for pair, name in markets: for pair, name in markets:
dfs = [] dfs = []
@@ -57,7 +56,7 @@ def import_kraken_trades_from_csv(config: Config, convert_to: str):
trades.loc[:, 'cost'] = trades['price'] * trades['amount'] trades.loc[:, 'cost'] = trades['price'] * trades['amount']
for col in DEFAULT_TRADES_COLUMNS: for col in DEFAULT_TRADES_COLUMNS:
if col not in trades.columns: if col not in trades.columns:
trades[col] = np.nan trades[col] = ''
trades = trades[DEFAULT_TRADES_COLUMNS] trades = trades[DEFAULT_TRADES_COLUMNS]
trades = trades_convert_types(trades) trades = trades_convert_types(trades)