From 03fe8a618c7724d326ffad5a9964ba345d36946c Mon Sep 17 00:00:00 2001 From: Liang Jiaqing Date: Fri, 26 Jun 2026 19:02:03 +0800 Subject: [PATCH] fix: limit parallel max_workers to 3 --- assets/ga_ultraplan.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/assets/ga_ultraplan.py b/assets/ga_ultraplan.py index 06e4f90d..4d617717 100644 --- a/assets/ga_ultraplan.py +++ b/assets/ga_ultraplan.py @@ -125,7 +125,7 @@ def parallel(tasks, max_workers=None, _label=None, **data): tasks = list(tasks); label = _label or f"parallel: {len(tasks)} tasks" with _lock: _current = label _op(label); _note(label) - with ThreadPoolExecutor(max_workers=max_workers or len(tasks) or 1) as ex: + with ThreadPoolExecutor(max_workers=max_workers or min(3, len(tasks) or 1)) as ex: return list(ex.map(lambda t: _run(t, data), tasks)) def mapchain(items, *steps, max_workers=None, **data):