From 0f24509c30ee60a533503f9958b9e568cc016ee4 Mon Sep 17 00:00:00 2001 From: Richard Liaw Date: Sun, 13 Oct 2019 15:25:15 -0700 Subject: [PATCH] [autoscaler] uptime redirect fix (#5907) * small change * comment --- python/ray/autoscaler/updater.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/python/ray/autoscaler/updater.py b/python/ray/autoscaler/updater.py index 6e581a669..00e6205b9 100644 --- a/python/ray/autoscaler/updater.py +++ b/python/ray/autoscaler/updater.py @@ -403,11 +403,11 @@ class NodeUpdater(object): logger.debug(self.log_prefix + "Waiting for remote shell...") - # Setting redirect=False allows the user to see errors like + # Setting redirect=None allows the user to see errors like # unix_listener: path "/tmp/rkn_ray_ssh_sockets/..." too # long for Unix domain socket. - self.cmd_runner.run("uptime", timeout=5, redirect=False) - + self.cmd_runner.run("uptime", timeout=5, redirect=None) + logger.debug("Uptime succeeded.") return True except Exception as e: @@ -429,6 +429,7 @@ class NodeUpdater(object): self.wait_ready(deadline) node_tags = self.provider.node_tags(self.node_id) + logger.debug("Node tags: {}".format(str(node_tags))) if node_tags.get(TAG_RAY_RUNTIME_CONFIG) == self.runtime_hash: logger.info(self.log_prefix + "{} already up-to-date, skip to ray start".format(