(self)
| 352 | self.engine.abort_request(request_ids) |
| 353 | |
| 354 | async def run_engine_loop(self): |
| 355 | # Initialize the RequestTracker here so it uses the right event loop. |
| 356 | has_requests_in_progress = False |
| 357 | while True: |
| 358 | if not has_requests_in_progress: |
| 359 | await self._request_tracker.wait_for_new_requests() |
| 360 | has_requests_in_progress = await self.engine_step() |
| 361 | await asyncio.sleep(0) |
| 362 | |
| 363 | async def add_request( |
| 364 | self, |
no test coverage detected