()
| 413 | next_running = None |
| 414 | |
| 415 | async def __no_running_warning(): |
| 416 | # TODO (JimyMa): add watermark check event instead of async sleep. |
| 417 | # self.perfill_watermark_event.wait() |
| 418 | logger.warning(f'no next prefill running request, Maybe cache is full, ' |
| 419 | f'free gpu cache blocks: {scheduler.block_manager.get_num_free_gpu_blocks()}, ' |
| 420 | f'total gpu cache blocks: {scheduler.block_manager.num_gpu_blocks}') |
| 421 | await asyncio.sleep(0.1) |
| 422 | |
| 423 | while not self.stop_event.is_set(): |
| 424 | if self._sleep_requested: |
nothing calls this directly
no test coverage detected