8cadb9c4b723cb9bd097234cfa739f9281945477,agents/a3c.py,A3C,learn,#A3C#,59

Before Change

        ps_process = subprocess.Popen([sys.executable, os.path.join(current_folder, "parameter_server.py"), str(self.config["n_tasks"])])
        worker_processes = []
        for task_id in range(self.config["n_tasks"]):
            p = subprocess.Popen([
                sys.executable,
                os.path.join(current_folder, "a3c_worker.py"),
                self.env_name,
                self.thread_type,
                str(task_id),
                str(self.config["n_tasks"]),
                self.config["config_path"],
                "--monitor_path", self.monitor_path
            ])
            worker_processes.append(p)
        for p in worker_processes:
            p.wait()
        ps_process.terminate()

After Change

                self.config["config_path"],
                "--monitor_path", self.monitor_path
            ]
            processed_cmd = " ".join(shlex_quote(str(x)) for x in cmd)
            p = subprocess.Popen(processed_cmd, shell=True)
            worker_processes.append(p)
        for p in worker_processes:
            p.wait()

Instances