Skip to content
Open
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
moree
  • Loading branch information
sshane committed Jul 26, 2025
commit f49c64d0aa2cd94ccaa52725eefd7a5ce6c2ef22
1 change: 0 additions & 1 deletion src/xdist/dsession.py
Original file line number Diff line number Diff line change
Expand Up @@ -523,7 +523,6 @@ def pytest_xdist_setupnodes(self, specs: Sequence[execnet.XSpec]) -> None:

@pytest.hookimpl
def pytest_xdist_newgateway(self, gateway: execnet.Gateway) -> None:
print('pytest_xdist_newgateway', gateway.id, gateway.spec)
if self.config.option.verbose > 0:
rinfo = gateway._rinfo()
different_interpreter = rinfo.executable != sys.executable
Expand Down
5 changes: 2 additions & 3 deletions src/xdist/workermanage.py
Original file line number Diff line number Diff line change
Expand Up @@ -101,8 +101,8 @@ def setup_nodes(
self.trace("setting up nodes")
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)
executor.submit(self.setup_node, spec, putevent)
for spec in self.specs
]
results = [f.result() for f in futs]
for r in results:
Expand All @@ -113,7 +113,6 @@ 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}")
Expand Down
Loading