(self, request, world_size)
| 340 | return skip_msg |
| 341 | |
| 342 | def _launch_with_file_store(self, request, world_size): |
| 343 | tmpdir = request.getfixturevalue("tmpdir") |
| 344 | |
| 345 | if isinstance(world_size, int): |
| 346 | world_size = [world_size] |
| 347 | for procs in world_size: |
| 348 | with tempfile.NamedTemporaryFile(delete=False, dir=str(tmpdir), suffix='_filestore') as fp: |
| 349 | init_method = f"file://{fp.name}" |
| 350 | self._launch_procs(procs, init_method) |
| 351 | time.sleep(0.5) |
| 352 | |
| 353 | def _dist_destroy(self): |
| 354 | if (dist is not None) and dist.is_initialized(): |
no test coverage detected