dashboard/modules/log/log_head.py
async def _wait_until_initialized(self):
        """
        Wait until connected to at least one node's log agent.
        """
        POLL_SLEEP_TIME = 0.5
        POLL_RETRIES = 10
        for _ in range(POLL_RETRIES):
            if self._stubs != {}:
                return None
            await asyncio.sleep(POLL_SLEEP_TIME)
        return aiohttp.web.HTTPGatewayTimeout(
            reason="Could not connect to agents via gRPC after "
            f"{POLL_SLEEP_TIME * POLL_RETRIES} seconds."
        )

        Wait until connected to at least one node's log agent.
        
Wait until connected to at least one node's log agent.
Wait until connected to at least one node ' s log agent .
async def _wait_until_initialized(self):
        POLL_SLEEP_TIME = 0.5
        POLL_RETRIES = 10
        for _ in range(POLL_RETRIES):
            if self._stubs != {}:
                return None
            await asyncio.sleep(POLL_SLEEP_TIME)
        return aiohttp.web.HTTPGatewayTimeout(
            reason="Could not connect to agents via gRPC after "
            f"{POLL_SLEEP_TIME * POLL_RETRIES} seconds."
        )
async def _wait_until_initialized ( self ) : POLL_SLEEP_TIME = 0.5 POLL_RETRIES = 10 for _ in range ( POLL_RETRIES ) : if self . _stubs != { } : return None await asyncio . sleep ( POLL_SLEEP_TIME ) return aiohttp . web . HTTPGatewayTimeout ( reason = "Could not connect to agents via gRPC after " f"{POLL_SLEEP_TIME * POLL_RETRIES} seconds." )
Wait until connected to at least one node's log agent.
Wait until connected to at least one node ' s log agent .
"""
        Wait until connected to at least one node's log agent.
        """
self