Method _run_loop

src/web/scheduler.py:46–55

执行调度轮询循环。

(self)

        logger.info("计划任务调度器已停止")

    async def _run_loop(self):
        """执行调度轮询循环。"""
        while self._running:
            try:
                await self.poll_due_jobs()
            except asyncio.CancelledError:
                raise
            except Exception as exc:
                logger.warning(f"计划任务轮询异常: {exc}")
            await asyncio.sleep(self.poll_interval_seconds)

    async def poll_due_jobs(self):
        """扫描并执行到期计划任务。"""