CTYPTO/freqtrade
1
0
Fork 0
mirror of https://github.com/freqtrade/freqtrade.git synced 2025-11-29 00:23:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix import error in one test case

Browse Source
This commit is contained in:
Matthias
2024-03-01 06:55:52 +01:00
parent 091d8275f5
commit baf2cf6967
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
freqtrade/data/converter/orderflow.py
View File

@@ -1,6 +1,5 @@
"""
Functions to convert orderflow data from public_trades
"""
import logging
import time
@@ -10,7 +9,6 @@ import pandas as pd
from pandas import DataFrame
from freqtrade.constants import DEFAULT_ORDERFLOW_COLUMNS, Config
from freqtrade.exchange.exchange_utils import timeframe_to_resample_freq
logger = logging.getLogger(__name__)
@@ -42,6 +40,7 @@ def _convert_timeframe_to_pandas_frequency(timeframe: str):
def _calculate_ohlcv_candle_start_and_end(df: DataFrame, timeframe: str):
from freqtrade.exchange.exchange_utils import timeframe_to_resample_freq
_, timeframe_minutes = _convert_timeframe_to_pandas_frequency(
timeframe)
@@ -51,8 +50,7 @@ def _calculate_ohlcv_candle_start_and_end(df: DataFrame, timeframe: str):
df['datetime'] = pd.to_datetime(df['date'], unit='ms')
df['candle_start'] = df['datetime'].dt.floor(timeframe_frequency)
# used in _now_is_time_to_refresh_trades
df['candle_end'] = df['candle_start'] + \
pd.Timedelta(minutes=timeframe_minutes)
df['candle_end'] = df['candle_start'] + pd.Timedelta(minutes=timeframe_minutes)
df.drop(columns=['datetime'], inplace=True)