async def METHOD_NAME(self) -> None:
    with log_context(
        logger, logging.INFO, f"{LoggingEventHandlerObserver.__name__} stop"
    ):
        self._stop_observer_process()
        self._keep_running = False
        if self._task_health_worker is not None:
            self._task_health_worker.cancel()
            with suppress(CancelledError):
                await self._task_health_worker