async def METHOD_NAME(self):
    while True:
        try:
            api = self._get_web_cluster_api()
            async for supervisors in api.watch_supervisors():
                yield supervisors
        except (OSError, asyncio.TimeoutError):
            pass