| 164 | self._launch_with_file_store(request, world_size) |
| 165 | |
| 166 | def _get_fixture_kwargs(self, request, func): |
| 167 | if not request: |
| 168 | return {} |
| 169 | # Grab fixture / parametrize kwargs from pytest request object |
| 170 | fixture_kwargs = {} |
| 171 | params = inspect.getfullargspec(func).args |
| 172 | params.remove("self") |
| 173 | for p in params: |
| 174 | try: |
| 175 | fixture_kwargs[p] = request.getfixturevalue(p) |
| 176 | except FixtureLookupError: |
| 177 | pass # test methods can have kwargs that are not fixtures |
| 178 | return fixture_kwargs |
| 179 | |
| 180 | def _launch_daemonic_procs(self, num_procs, init_method): |
| 181 | # Create process pool or use cached one |