diff --git a/python/ray/autoscaler/autoscaler.py b/python/ray/autoscaler/autoscaler.py index 40ffbddd913af..1d3d76565ac55 100644 --- a/python/ray/autoscaler/autoscaler.py +++ b/python/ray/autoscaler/autoscaler.py @@ -729,19 +729,11 @@ def request_resources(self, resources): def kill_workers(self): logger.error("StandardAutoscaler: kill_workers triggered") - - while True: - try: - nodes = self.workers() - if nodes: - self.provider.terminate_nodes(nodes) - logger.error( - "StandardAutoscaler: terminated {} node(s)".format( - len(nodes))) - except Exception: - traceback.print_exc() - - time.sleep(10) + nodes = self.workers() + if nodes: + self.provider.terminate_nodes(nodes) + logger.error("StandardAutoscaler: terminated {} node(s)".format( + len(nodes))) def typename(v):