diff --git a/src/daemon/ticker.py b/src/daemon/ticker.py index 8e05053..ceb87a3 100644 --- a/src/daemon/ticker.py +++ b/src/daemon/ticker.py @@ -104,6 +104,13 @@ class Ticker: async def stop(self) -> None: """停止 tick 循环""" self._running = False + # 停止 InboxWatcher + if self.inbox_watcher: + try: + await self.inbox_watcher.stop() + logger.info("InboxWatcher stopped") + except Exception as e: + logger.warning("InboxWatcher stop failed: %s", e) if self._task: self._task.cancel() try: