Lower threshold on scalability envelope many tasks (ray-project#17511)

daikeshi · Aug 2, 2021 · af88037 · af88037
1 parent 748cbbb
commit af88037
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/benchmarks/distributed/test_many_tasks.py b/benchmarks/distributed/test_many_tasks.py
@@ -35,7 +35,7 @@ def task():
     # There are some relevant magic numbers in this check. 10k tasks each
     # require 1/4 cpus. Therefore, ideally 2.5k cpus will be used.
     err_str = f"Only {max_cpus - min_cpus_available}/{max_cpus} cpus used."
-    threshold = num_tasks * cpus_per_task * 0.9
+    threshold = num_tasks * cpus_per_task * 0.75
     assert max_cpus - min_cpus_available > threshold, err_str
 
     for _ in tqdm.trange(num_tasks, desc="Ensuring all tasks have finished"):