def get_with_failure_handling(self, remote_values):
    'Gets the remote values while handling for worker failures.\n\n        Args:\n            remote_values (list): List of object refs representing functions\n                that may fail in the middle of execution. For example, running\n                a SGD training loop in multiple parallel actor calls.\n\n        Returns:\n            The resolved objects represented by the passed in ObjectRefs.\n        '
    unfinished = remote_values
    try:
        while (len(unfinished) > 0):
            (finished, unfinished) = ray.wait(unfinished)
            ray.get(finished)
    except RayActorError as exc:
        logger.exception(str(exc))
        self.handle_failure()
        return
    return ray.get(remote_values)
Gets the remote values while handling for worker failures.

Args:
    remote_values (list): List of object refs representing functions
        that may fail in the middle of execution. For example, running
        a SGD training loop in multiple parallel actor calls.

Returns:
    The resolved objects represented by the passed in ObjectRefs.
def get_with_failure_handling(self, remote_values):
    'Gets the remote values while handling for worker failures.\n\n        Args:\n            remote_values (list): List of object refs representing functions\n                that may fail in the middle of execution. For example, running\n                a SGD training loop in multiple parallel actor calls.\n\n        Returns:\n            The resolved objects represented by the passed in ObjectRefs.\n        '
    unfinished = remote_values
    try:
        while (len(unfinished) > 0):
            (finished, unfinished) = ray.wait(unfinished)
            ray.get(finished)
    except RayActorError as exc:
        logger.exception(str(exc))
        self.handle_failure()
        return
    return ray.get(remote_values)