async def METHOD_NAME(self, sig: Optional[int] = None):
    logger.info("Waiting for gRPC server shutdown")
    # TODO: Read from config
    await self._server.METHOD_NAME(grace=5)
    logger.info("gRPC server shutdown complete")