(self)
| 135 | process.join() |
| 136 | |
| 137 | def restart_all(self) -> None: |
| 138 | for idx, process in enumerate(self.processes): |
| 139 | process.terminate() |
| 140 | process.join() |
| 141 | new_process = Process(self.config, self.target, self.sockets) |
| 142 | new_process.start() |
| 143 | self.processes[idx] = new_process |
| 144 | |
| 145 | def run(self) -> None: |
| 146 | message = f"Started parent process [{os.getpid()}]" |
no test coverage detected