From 74192f454fbefcecf030406327941b5ae1a669e8 Mon Sep 17 00:00:00 2001 From: YueGuobin Date: Tue, 16 Jun 2026 00:49:08 +0800 Subject: [PATCH] Increase BATCH_MAX_WORKERS and Pool concurrency from 20 to 100 --- gns3server/api/routes/mcp/links.py | 2 +- gns3server/api/routes/mcp/nodes.py | 2 +- gns3server/controller/project.py | 4 ++-- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/gns3server/api/routes/mcp/links.py b/gns3server/api/routes/mcp/links.py index 4b3837f55..2a2f6f0ef 100644 --- a/gns3server/api/routes/mcp/links.py +++ b/gns3server/api/routes/mcp/links.py @@ -31,7 +31,7 @@ from gns3server.services import auth_service log = logging.getLogger(__name__) -BATCH_MAX_WORKERS = 10 +BATCH_MAX_WORKERS = 100 # ── Helper ───────────────────────────────────────────────────────────────── diff --git a/gns3server/api/routes/mcp/nodes.py b/gns3server/api/routes/mcp/nodes.py index 66920ea3f..c14542ec8 100644 --- a/gns3server/api/routes/mcp/nodes.py +++ b/gns3server/api/routes/mcp/nodes.py @@ -31,7 +31,7 @@ from gns3server.services import auth_service log = logging.getLogger(__name__) -BATCH_MAX_WORKERS = 10 +BATCH_MAX_WORKERS = 100 # ── Constants ────────────────────────────────────────────────────────────── diff --git a/gns3server/controller/project.py b/gns3server/controller/project.py index bed55eb60..ae1da65e0 100644 --- a/gns3server/controller/project.py +++ b/gns3server/controller/project.py @@ -1296,7 +1296,7 @@ class Project: # Create nodes in parallel with limited concurrency # to avoid overwhelming the system with too many simultaneous operations - pool = Pool(concurrency=20) + pool = Pool(concurrency=100) for compute, name, node_id, node_data in nodes_to_create: pool.append(self.add_node, compute, name, node_id, dump=False, **node_data) await pool.join() @@ -1314,7 +1314,7 @@ class Project: if count > 0: await self.preallocate_udp_ports_for_compute(compute, count) # Create links in parallel for improved performance - pool = Pool(concurrency=20) + pool = Pool(concurrency=100) for link_data in topology.get("links", []): if "link_id" not in link_data.keys(): continue