diff --git a/scripts/start-hyperopt-worker.py b/scripts/start-hyperopt-worker.py index db80ec8de..8b0ae6326 100755 --- a/scripts/start-hyperopt-worker.py +++ b/scripts/start-hyperopt-worker.py @@ -2,8 +2,7 @@ import multiprocessing import os import subprocess -import sys -import shlex + PROC_COUNT = multiprocessing.cpu_count() - 1 DB_NAME = 'freqtrade_hyperopt' WORK_DIR = os.path.join( @@ -20,9 +19,9 @@ command = [ '--mongo=127.0.0.1:1234/{}'.format(DB_NAME), '--poll-interval=0.1', '--workdir={}'.format(WORK_DIR), - '--max-jobs=100000', - '--max-consecutive-failures=100000', ] -def run(command): - subprocess.call(command, shell=True)) -run(command) +processes = [subprocess.Popen(command) for i in range(PROC_COUNT)] + +# Join all workers +for proc in processes: + proc.wait()