(self, pool, num_procs, force=False)
| 356 | dist.destroy_process_group() |
| 357 | |
| 358 | def _close_pool(self, pool, num_procs, force=False): |
| 359 | if force or not self.reuse_dist_env: |
| 360 | pool.starmap(self._dist_destroy, [() for _ in range(num_procs)]) |
| 361 | pool.close() |
| 362 | pool.join() |
| 363 | |
| 364 | |
| 365 | class DistributedFixture(DistributedExec): |