82f9c7014e2d0acd3e3869066f5dc3142ec9e7a7,python/ray/autoscaler/_private/command_runner.py,KubernetesCommandRunner,_home,#KubernetesCommandRunner#,250

Before Change

    def _home(self):
        // TODO (Dmitri): Think about how to use the node"s HOME variable
        // without making an extra kubectl exec call.
        if self._home_cached is None:
            cmd = self.kubectl + [
                "exec", "-it", self.node_id, "--", "printenv", "HOME"
            ]
            joined_cmd = " ".join(cmd)
            raw_out = self.process_runner.check_output(joined_cmd, shell=True)
            self._home_cached = raw_out.decode().strip("\n\r")
        return self._home_cached


class SSHOptions:

After Change

        for _ in range(MAX_HOME_RETRIES - 1):
            try:
                self._home_cached = self._try_to_get_home()
                return self._home_cached
            except Exception:
                // TODO (Dmitri): Identify the exception we"re trying to avoid.
                logger.info("Error reading container"s home directory. "
                            f"Retrying in {HOME_RETRY_DELAY_S} seconds.")

Instances