wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-04 14:48:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

[autoscaler] uptime redirect fix (#5907)

Browse Source 
* small change

* comment
This commit is contained in:
Richard Liaw
2019-10-13 15:25:15 -07:00
committed by Edward Oakes
parent 6eaa8e31fa
commit 0f24509c30
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
python/ray/autoscaler/updater.py
+4 -3
View File
@@ -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(