Skip to content

Commit 26f5c3e

Browse files
Guillaume De Saint MartinGuillaumeDSM
authored andcommitted
[ModeProducer] do not flush db on default producer trigger
1 parent d89085c commit 26f5c3e

File tree

2 files changed

+11
-5
lines changed

2 files changed

+11
-5
lines changed

octobot_trading/modes/channel/abstract_mode_producer.py

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -325,11 +325,7 @@ async def trading_mode_trigger(self):
325325
await self.post_trigger()
326326

327327
async def post_trigger(self):
328-
if not self.exchange_manager.is_backtesting:
329-
# update db after each run only in live mode
330-
for database in self.all_databases().values():
331-
if database:
332-
await database.flush()
328+
pass
333329

334330
async def set_final_eval(self, matrix_id: str, cryptocurrency: str, symbol: str, time_frame,
335331
trigger_source: str) -> None:

octobot_trading/modes/scripted_trading_mode/abstract_scripted_trading_mode.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -292,3 +292,13 @@ async def call_script(self, matrix_id: str, cryptocurrency: str, symbol: str, ti
292292

293293
async def _pre_script_call(self, context):
294294
await basic_keywords.set_leverage(context, await basic_keywords.user_select_leverage(context))
295+
296+
async def post_trigger(self):
297+
if not self.exchange_manager.is_backtesting:
298+
# update db after each run only in live mode
299+
for database in self.all_databases().values():
300+
if database:
301+
try:
302+
await database.flush()
303+
except Exception as err:
304+
self.logger.exception(err, True, f"Error when flushing database: {err}")

0 commit comments

Comments
 (0)