From 473c40b81224e48d93d0704ac42c6d817f473de5 Mon Sep 17 00:00:00 2001 From: Joost VandeVondele Date: Sun, 23 Apr 2023 15:55:51 +0200 Subject: [PATCH] limit the batch size amplification --- server/fishtest/rundb.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/server/fishtest/rundb.py b/server/fishtest/rundb.py index 3ba6b1f7f..d9b5ce842 100644 --- a/server/fishtest/rundb.py +++ b/server/fishtest/rundb.py @@ -647,7 +647,7 @@ def worker_cap(self, run, worker_info): 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 + (len(run["tasks"]) // 250) + scale_duration = 1 + min(4, len(run["tasks"]) // 250) games = self.task_duration * scale_duration / game_time * concurrency if "sprt" in run["args"]: batch_size = 2 * run["args"]["sprt"].get("batch_size", 1)