async def async_update(self):
    'Update our state from the Agent API.'
    try:
        (await self.device.update())
        if self._removed:
            _LOGGER.debug('%s reacquired', self._name)
        self._removed = False
    except AgentError:
        if self.device.client.is_available:
            if (not self._removed):
                _LOGGER.error('%s lost', self._name)
                self._removed = True
Update our state from the Agent API.
async def async_update(self):
    
    try:
        (await self.device.update())
        if self._removed:
            _LOGGER.debug('%s reacquired', self._name)
        self._removed = False
    except AgentError:
        if self.device.client.is_available:
            if (not self._removed):
                _LOGGER.error('%s lost', self._name)
                self._removed = True