diff --git a/python/ray/autoscaler/updater.py b/python/ray/autoscaler/updater.py index 36aec9bf0..6cbcc761f 100644 --- a/python/ray/autoscaler/updater.py +++ b/python/ray/autoscaler/updater.py @@ -220,12 +220,12 @@ class NodeUpdater(object): m = "{}: Initialization commands completed".format(self.node_id) with LogTimer("NodeUpdater: {}".format(m)): for cmd in self.initialization_commands: - self.ssh_cmd(cmd, redirect=open("/dev/null", "w")) + self.ssh_cmd(cmd) m = "{}: Setup commands completed".format(self.node_id) with LogTimer("NodeUpdater: {}".format(m)): for cmd in self.setup_commands: - self.ssh_cmd(cmd, redirect=open("/dev/null", "w")) + self.ssh_cmd(cmd) def rsync_up(self, source, target, redirect=None, check_error=True): self.set_ssh_ip_if_required()