Preserve mirrored pytest-xdist version

for more information, see https://pre-commit.ci

pyproject.toml

@@ -1,12 +1,12 @@
 [build-system]
 requires = [
   "setuptools>=77.0",
-  "setuptools-scm[toml]>=6.2.3",
 ]
 build-backend = "setuptools.build_meta"
 
 [project]
 name = "pytest-xdist"
+version = "3.7.1.dev24+g2b4372bd6"
 description = "pytest xdist plugin for distributed testing, most importantly across multiple CPUs"
 readme = "README.rst"
 license = "MIT"
@@ -35,7 +35,6 @@ dependencies = [
     "execnet>=2.1",
     "pytest>=7.0.0",
 ]
-dynamic = ["version"]
 
 [project.urls]
 Homepage = "https://github.com/pytest-dev/pytest-xdist"
@@ -53,9 +52,6 @@ testing = ["filelock"]
 psutil = ["psutil>=3.0"]
 setproctitle = ["setproctitle"]
 
-[tool.setuptools_scm]
-write_to = "src/xdist/_version.py"
-
 [tool.pytest.ini_options]
 # pytest-services also defines a worker_id fixture, disable
 # it so they don't conflict with each other (#611).

src/xdist/__init__.py

@@ -1,10 +1,12 @@
-from xdist._version import version as __version__
 from xdist.plugin import get_xdist_worker_id
 from xdist.plugin import is_xdist_controller
 from xdist.plugin import is_xdist_master
 from xdist.plugin import is_xdist_worker
 
 
+__version__ = "3.7.1.dev24+g2b4372bd6"
+
+
 __all__ = [
     "__version__",
     "get_xdist_worker_id",

src/xdist/workermanage.py

@@ -1,6 +1,7 @@
 from __future__ import annotations
 
 from collections.abc import Sequence
+from concurrent.futures import ThreadPoolExecutor
 import enum
 import fnmatch
 import os
@@ -94,15 +95,23 @@ class NodeManager:
     ) -> list[WorkerController]:
         self.config.hook.pytest_xdist_setupnodes(config=self.config, specs=self.specs)
         self.trace("setting up nodes")
-        return [self.setup_node(spec, putevent) for spec in self.specs]
+        with ThreadPoolExecutor(max_workers=len(self.specs)) as executor:
+            futs = [
+                executor.submit(self.setup_node, spec, putevent, idx)
+                for idx, spec in enumerate(self.specs)
+            ]
+            return [f.result() for f in futs]
 
     def setup_node(
         self,
         spec: execnet.XSpec,
         putevent: Callable[[tuple[str, dict[str, Any]]], None],
+        idx: int | None = None,
     ) -> WorkerController:
         if getattr(spec, "execmodel", None) != "main_thread_only":
             spec = execnet.XSpec(f"execmodel=main_thread_only//{spec}")
+        if idx is not None:
+            spec = execnet.XSpec(f"{spec}//id=gw{idx}")
         gw = self.group.makegateway(spec)
         self.config.hook.pytest_xdist_newgateway(gateway=gw)
         self.rsync_roots(gw)

testing/test_workermanage.py

@@ -82,11 +82,19 @@ class TestNodeManagerPopen:
         call = hookrecorder.popcall("pytest_xdist_setupnodes")
         assert len(call.specs) == 2
 
-        call = hookrecorder.popcall("pytest_xdist_newgateway")
-        assert call.gateway.spec == execnet.XSpec("execmodel=main_thread_only//popen")
-        assert call.gateway.id == "gw0"
-        call = hookrecorder.popcall("pytest_xdist_newgateway")
-        assert call.gateway.id == "gw1"
+        # check expected gateways
+        gw_calls = [
+            hookrecorder.popcall("pytest_xdist_newgateway"),
+            hookrecorder.popcall("pytest_xdist_newgateway"),
+        ]
+        assert {c.gateway.id for c in gw_calls} == {"gw0", "gw1"}
+
+        for c in gw_calls:
+            expected_spec = execnet.XSpec(
+                f"execmodel=main_thread_only//popen//id={c.gateway.id}"
+            )
+            assert c.gateway.spec == expected_spec
+
         assert len(hm.group) == 2
         hm.teardown_nodes()
         assert not len(hm.group)