add Config.IS_EXECUTION

This commit is contained in:
tef 2022-02-04 06:47:48 -05:00
parent cbe2fb80f3
commit 42645aee00
5 changed files with 7 additions and 6 deletions

View File

@ -171,7 +171,7 @@ class Strategy002(IStrategy):
brain = "Freq_" + self.__class__.__name__ brain = "Freq_" + self.__class__.__name__
if Config.IS_BACKTEST: if Config.IS_BACKTEST:
back_test(current_time, coin, brain) back_test(current_time, coin, brain)
else: elif Config.IS_EXECUTION:
execute(mode, coin, brain) execute(mode, coin, brain)
return True return True

View File

@ -186,6 +186,6 @@ class Strategy003(IStrategy):
brain = "Freq_" + self.__class__.__name__ brain = "Freq_" + self.__class__.__name__
if Config.IS_BACKTEST: if Config.IS_BACKTEST:
back_test(current_time, coin, brain) back_test(current_time, coin, brain)
else: elif Config.IS_EXECUTION:
execute(mode, coin, brain) execute(mode, coin, brain)
return True return True

View File

@ -186,6 +186,6 @@ class Strategy004(IStrategy):
brain = "Freq_" + self.__class__.__name__ brain = "Freq_" + self.__class__.__name__
if Config.IS_BACKTEST: if Config.IS_BACKTEST:
back_test(current_time, coin, brain) back_test(current_time, coin, brain)
else: elif Config.IS_EXECUTION:
execute(mode, coin, brain) execute(mode, coin, brain)
return True return True

View File

@ -4,6 +4,7 @@ class Config:
BACKTEST_DATA_CLEANER_YEAR = 2020 BACKTEST_DATA_CLEANER_YEAR = 2020
BACKTEST_DATA_CLEANER_MONTH_INDEX = 9 BACKTEST_DATA_CLEANER_MONTH_INDEX = 9
IS_BACKTEST = False IS_BACKTEST = False
IS_EXECUTION = True
WORKSPACE_PATH = "workspace2" if IS_BACKTEST else "workspace" WORKSPACE_PATH = "workspace2" if IS_BACKTEST else "workspace"
EXECUTION_PATH = "/root/" + WORKSPACE_PATH + "/execution/" EXECUTION_PATH = "/root/" + WORKSPACE_PATH + "/execution/"
IS_PARALLER_EXECUTION = True IS_PARALLEL_EXECUTION = True

View File

@ -3,7 +3,7 @@ import threading
from user_data.strategies.config import Config from user_data.strategies.config import Config
def execute(mode, coin, brain): def execute(mode, coin, brain):
if Config.IS_PARALLER_EXECUTION: if Config.IS_PARALLEL_EXECUTION:
threading.Thread(target=_perform_execute, args=(mode, coin, brain)).start() threading.Thread(target=_perform_execute, args=(mode, coin, brain)).start()
else: else:
_perform_execute(mode, coin, brain) _perform_execute(mode, coin, brain)
@ -17,7 +17,7 @@ def _perform_back_test(date_time, coin, brain):
subprocess.call("python3 "+ Config.EXECUTION_PATH + "back_tester.py " + date + " " + coin + " " + brain + " 0.45 3", shell=True) subprocess.call("python3 "+ Config.EXECUTION_PATH + "back_tester.py " + date + " " + coin + " " + brain + " 0.45 3", shell=True)
def back_test(date_time, coin, brain): def back_test(date_time, coin, brain):
if Config.IS_PARALLER_EXECUTION: if Config.IS_PARALLEL_EXECUTION:
threading.Thread(target=_perform_back_test, args=(date_time, coin, brain)).start() threading.Thread(target=_perform_back_test, args=(date_time, coin, brain)).start()
else: else:
_perform_back_test(date_time, coin, brain) _perform_back_test(date_time, coin, brain)