Added informational output. Pretty much complete.
This commit is contained in:
parent
761fb92d2d
commit
48680feb44
@ -46,10 +46,14 @@ print("Starting pp with", job_server.get_ncpus(), "workers")
|
|||||||
|
|
||||||
start_time = time.time()
|
start_time = time.time()
|
||||||
index = 1
|
index = 1
|
||||||
|
|
||||||
|
print('Please wait... sending jobs to server')
|
||||||
while parts > index:
|
while parts > index:
|
||||||
jobs.append(job_server.submit(backtesting, (index,)))
|
jobs.append(job_server.submit(backtesting, (index,)))
|
||||||
index += 1
|
index += 1
|
||||||
while True:
|
while True:
|
||||||
|
print('Searching... in loop... waiting 15s')
|
||||||
|
time.sleep(15)
|
||||||
for job in jobs:
|
for job in jobs:
|
||||||
try:
|
try:
|
||||||
res = job()
|
res = job()
|
||||||
@ -86,5 +90,3 @@ while True:
|
|||||||
job_server.print_stats()
|
job_server.print_stats()
|
||||||
except:
|
except:
|
||||||
pass
|
pass
|
||||||
print('Searching... in loop... waiting 30s')
|
|
||||||
time.sleep(30)
|
|
||||||
|
Loading…
Reference in New Issue
Block a user