(store: LightningStore, worker_id: int, event: ExecutionEvent)
| 400 | |
| 401 | |
| 402 | async def _timeout_error_in_runner(store: LightningStore, worker_id: int, event: ExecutionEvent) -> None: |
| 403 | # Provoke client's validation (pre-request), then raise TimeoutError. |
| 404 | with pytest.raises(ValueError): |
| 405 | await store.wait_for_rollouts(rollout_ids=["r1"], timeout=0.2) |
| 406 | _ = worker_id |
| 407 | event.set() |
| 408 | raise TimeoutError("runner timeout") |
| 409 | |
| 410 | |
| 411 | async def _waiting_for_rollout_runner(store: LightningStore, worker_id: int, event: ExecutionEvent) -> None: |
nothing calls this directly
no test coverage detected