36e46ed923ae809e50bfeaca1628e834028616e5,python/ray/autoscaler/_private/command_runner.py,KubernetesCommandRunner,run_rsync_down,#KubernetesCommandRunner#,220

Before Change

            ])

    def run_rsync_down(self, source, target, options=None):
        if source.startswith("~"):
            source = self.home + source[1:]

        try:
            flags = "-aqz" if is_rsync_silent() else "-avz"
            self.process_runner.check_call([
                KUBECTL_RSYNC,

After Change

                self.log_prefix +
                "rsync failed: "{}". Falling back to "kubectl cp"".format(e),
                UserWarning)
            if target.startswith("~"):
                target = RAY_HOME + target[1:]

            self.process_runner.check_call(self.kubectl + [
                "cp", "{}/{}:{}".format(self.namespace, self.node_id, source),
                target
            ])

Instances