启动计划任务调度器。
(self)
| 23 | self._running = False |
| 24 | |
| 25 | async def start(self): |
| 26 | """启动计划任务调度器。""" |
| 27 | if self._task and not self._task.done(): |
| 28 | return |
| 29 | self._running = True |
| 30 | self._task = asyncio.create_task(self._run_loop()) |
| 31 | logger.info("计划任务调度器已启动,轮询间隔 %s 秒", self.poll_interval_seconds) |
| 32 | |
| 33 | async def stop(self): |
| 34 | """停止计划任务调度器。""" |
no test coverage detected