oops

longshotsyndicate · Mar 21, 2019 · f47c24a · f47c24a
1 parent 3aa341f
commit f47c24a
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/python/ray/autoscaler/autoscaler.py b/python/ray/autoscaler/autoscaler.py
@@ -524,11 +524,8 @@ def target_num_workers(self):
             # If we want any workers, we want at least initial_workers
             ideal_num_workers = max(ideal_num_workers, initial_workers)
 
-        upper = min(self.config["max_workers"], ideal_num_workers)
-        lower = self.config["min_workers"]
-        tgt = max(lower, upper)
-
-        return tgt
+        return min(self.config["max_workers"],
+                   max(self.config["min_workers"], ideal_num_workers))
 
     def launch_config_ok(self, node_id):
         launch_conf = self.provider.node_tags(node_id).get(