add back_test throttle

This commit is contained in:
tef 2022-02-10 05:08:39 -05:00
parent 42645aee00
commit dcbdaec4a2
2 changed files with 3 additions and 0 deletions

View File

@ -8,3 +8,4 @@ class Config:
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_PARALLEL_EXECUTION = True IS_PARALLEL_EXECUTION = True
BACKTEST_THROTTLE_SECOND = 1

View File

@ -1,6 +1,7 @@
import subprocess import subprocess
import threading import threading
from user_data.strategies.config import Config from user_data.strategies.config import Config
import time
def execute(mode, coin, brain): def execute(mode, coin, brain):
if Config.IS_PARALLEL_EXECUTION: if Config.IS_PARALLEL_EXECUTION:
@ -17,6 +18,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):
time.sleep(Config.BACKTEST_THROTTLE_SECOND)
if Config.IS_PARALLEL_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: