increase candle update flexibility to allow long sequential trainings that may last more than one candle
This commit is contained in:
parent
66800c7a45
commit
d9b79d94e4
@ -866,15 +866,22 @@ class FreqaiDataKitchen:
|
|||||||
|
|
||||||
for pair in self.all_pairs:
|
for pair in self.all_pairs:
|
||||||
for tf in self.freqai_config.get('timeframes'):
|
for tf in self.freqai_config.get('timeframes'):
|
||||||
|
|
||||||
# check if newest candle is already appended
|
# check if newest candle is already appended
|
||||||
|
df_dp = strategy.dp.get_pair_dataframe(pair, tf)
|
||||||
if (
|
if (
|
||||||
str(history_data[pair][tf].iloc[-1]['date']) ==
|
str(history_data[pair][tf].iloc[-1]['date']) ==
|
||||||
str(strategy.dp.get_pair_dataframe(pair, tf).iloc[-1:]['date'].iloc[-1])
|
str(df_dp.iloc[-1:]['date'].iloc[-1])
|
||||||
):
|
):
|
||||||
continue
|
continue
|
||||||
|
|
||||||
|
index = df_dp.loc[
|
||||||
|
df_dp['date'] ==
|
||||||
|
history_data[pair][tf].iloc[-1]['date']
|
||||||
|
].index[0] + 1
|
||||||
history_data[pair][tf] = pd.concat(
|
history_data[pair][tf] = pd.concat(
|
||||||
[history_data[pair][tf],
|
[history_data[pair][tf],
|
||||||
strategy.dp.get_pair_dataframe(pair, tf).iloc[-1:]],
|
strategy.dp.get_pair_dataframe(pair, tf).iloc[index:]],
|
||||||
ignore_index=True, axis=0
|
ignore_index=True, axis=0
|
||||||
)
|
)
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user