(self)
| 308 | restart_task.add_done_callback(self.background_tasks.discard) |
| 309 | |
| 310 | async def _scheduler_loop(self) -> None: |
| 311 | self.logger.info("Scheduler loop started.") |
| 312 | while self.running: |
| 313 | try: |
| 314 | await self._schedule_pending_tasks() |
| 315 | await asyncio.sleep(0.01) |
| 316 | except Exception: |
| 317 | self.logger.error(f"Error in scheduler loop:\n{traceback.format_exc()}") |
| 318 | await asyncio.sleep(0.1) |
| 319 | self.logger.info("Scheduler loop stopped.") |
| 320 | |
| 321 | async def _monitor_runner_state_loop(self) -> None: |
| 322 | interval = self.config.explorer.runner_state_report_interval |
no test coverage detected