(self)
| 351 | time.sleep(0.5) |
| 352 | |
| 353 | def _dist_destroy(self): |
| 354 | if (dist is not None) and dist.is_initialized(): |
| 355 | dist.barrier() |
| 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: |
nothing calls this directly
no test coverage detected