Wait for pool.imap to finish before calling trader.train

Author: notadamking

data/params.db

@@ -3,6 +3,8 @@
 
 from multiprocessing import Pool
 
+from lib.env.reward import WeightedUnrealizedProfit
+
 np.warnings.filterwarnings('ignore')
 
 
@@ -12,15 +14,19 @@ def optimize_code(params):
     trader = RLTrader(**params)
     trader.optimize()
 
+    return ""
+
 
 if __name__ == '__main__':
     n_processes = multiprocessing.cpu_count()
-    params = {'n_envs': n_processes}
+    params = {'n_envs': n_processes, 'reward_strategy': WeightedUnrealizedProfit}
 
     opt_pool = Pool(processes=n_processes)
-    opt_pool.imap(optimize_code, [params for _ in range(n_processes)])
+    results = opt_pool.imap(optimize_code, [params for _ in range(n_processes)])
+
+    print([result.get() for result in results])
 
     from lib.RLTrader import RLTrader
 
     trader = RLTrader(**params)
-    trader.train(test_trained_model=True, render_test_env=True, render_report=True)
+    trader.train(test_trained_model=True, render_test_env=True, render_report=True, save_report=True)