(self, rollout_ids: Sequence[str], timeout: float)
| 74 | return result |
| 75 | |
| 76 | async def wait_for_rollouts(self, rollout_ids: Sequence[str], timeout: float) -> List[Rollout]: |
| 77 | self.wait_calls.append({"rollout_ids": tuple(rollout_ids), "timeout": timeout}) |
| 78 | if self.wait_results_queue: |
| 79 | return self.wait_results_queue.pop(0) |
| 80 | return [] |
| 81 | |
| 82 | async def query_spans( |
| 83 | self, |
no test coverage detected