diff --git a/server/fishtest/rundb.py b/server/fishtest/rundb.py index 1b2caa958..1a6dfb911 100644 --- a/server/fishtest/rundb.py +++ b/server/fishtest/rundb.py @@ -873,10 +873,7 @@ def worker_cap(self, run, worker_info): game_time = estimate_game_duration(run["args"]["tc"]) concurrency = worker_info["concurrency"] // run["args"]["threads"] assert concurrency >= 1 - # as we have more tasks done (>250), make them longer to avoid - # having many tasks in long running tests - scale_duration = 1 + min(4, len(run["tasks"]) // 250) - games = self.task_duration * scale_duration / game_time * concurrency + games = self.task_duration / game_time * concurrency if "sprt" in run["args"]: batch_size = 2 * run["args"]["sprt"].get("batch_size", 1) games = max(batch_size, batch_size * int(games / batch_size + 1 / 2))