python/ray/util/client/dataclient.py
def _can_reconnect(self, e: grpc.RpcError) -> bool:
        """
        Processes RPC errors that occur while reading from data stream.
        Returns True if the error can be recovered from, False otherwise.
        """
        if not self.client_worker._can_reconnect(e):
            logger.error("Unrecoverable error in data channel.")
            logger.debug(e)
            return False
        logger.debug("Recoverable error in data channel.")
        logger.debug(e)
        return True

        Processes RPC errors that occur while reading from data stream.
        Returns True if the error can be recovered from, False otherwise.
        
Processes RPC errors that occur while reading from data stream.
Returns True if the error can be recovered from, False otherwise.
Processes RPC errors that occur while reading from data stream . Returns True if the error can be recovered from False otherwise .
def _can_reconnect(self, e: grpc.RpcError) -> bool:
        if not self.client_worker._can_reconnect(e):
            logger.error("Unrecoverable error in data channel.")
            logger.debug(e)
            return False
        logger.debug("Recoverable error in data channel.")
        logger.debug(e)
        return True
def _can_reconnect ( self , e : grpc . RpcError ) -> bool : if not self . client_worker . _can_reconnect ( e ) : logger . error ( "Unrecoverable error in data channel." ) logger . debug ( e ) return False logger . debug ( "Recoverable error in data channel." ) logger . debug ( e ) return True
Processes RPC errors that occur while reading from data stream.
Processes RPC errors that occur while reading from data stream .
"""
        Processes RPC errors that occur while reading from data stream.
        Returns True if the error can be recovered from, False otherwise.
        """
self
e
grpc.RpcError