[pre-commit.ci] auto fixes from pre-commit.com hooks

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

Author: pre-commit-ci[bot]

src/xdist/scheduler/__init__.py

@@ -4,5 +4,7 @@
 from xdist.scheduler.loadgroup import LoadGroupScheduling as LoadGroupScheduling
 from xdist.scheduler.loadscope import LoadScopeScheduling as LoadScopeScheduling
 from xdist.scheduler.protocol import Scheduling as Scheduling
-from xdist.scheduler.singlecollect import SingleCollectScheduling as SingleCollectScheduling
+from xdist.scheduler.singlecollect import (
+    SingleCollectScheduling as SingleCollectScheduling,
+)
 from xdist.scheduler.worksteal import WorkStealingScheduling as WorkStealingScheduling

src/xdist/scheduler/singlecollect.py

@@ -12,12 +12,12 @@
 
 class SingleCollectScheduling:
     """Implement scheduling with a single test collection phase.
-    
+
     This differs from LoadScheduling by:
     1. Only collecting tests on the first node
     2. Skipping collection on other nodes
     3. Not checking for collection equality
-    
+
     This can significantly improve startup time by avoiding redundant collection
     and collection verification across multiple worker processes.
     """
@@ -72,7 +72,7 @@ def add_node(self, node: WorkerController) -> None:
         """Add a new node to the scheduler."""
         assert node not in self.node2pending
         self.node2pending[node] = []
-        
+
         # Remember the first node as our collector
         if self.first_node is None:
             self.first_node = node
@@ -145,11 +145,11 @@ def check_schedule(self, node: WorkerController, duration: float = 0) -> None:
     def remove_node(self, node: WorkerController) -> str | None:
         """Remove a node from the scheduler."""
         pending = self.node2pending.pop(node)
-        
+
         # If this is the first node (collector), reset it
         if node == self.first_node:
             self.first_node = None
-            
+
         if not pending:
             return None
 
@@ -208,4 +208,4 @@ def _send_tests(self, node: WorkerController, num: int) -> None:
         if tests_per_node:
             del self.pending[:num]
             self.node2pending[node].extend(tests_per_node)
-            node.send_runtest_some(tests_per_node)
+            node.send_runtest_some(tests_per_node)

testing/acceptance_test.py

@@ -25,7 +25,7 @@ def test_ok():
         result.stdout.fnmatch_lines(["*1 passed*"])
         # Make sure the tests are correctly distributed
         result.stdout.fnmatch_lines(["*scheduling tests via SingleCollectScheduling*"])
-    
+
     def test_singlecollect_many_tests(self, pytester: pytest.Pytester) -> None:
         """Test that the singlecollect mode correctly distributes many tests."""
         # Create test file with multiple tests
@@ -42,7 +42,7 @@ def test_ok(x):
         result.stdout.fnmatch_lines(["*passed*"])
         # Make sure the tests are correctly distributed
         result.stdout.fnmatch_lines(["*scheduling tests via SingleCollectScheduling*"])
-    
+
     def test_singlecollect_failure(self, pytester: pytest.Pytester) -> None:
         """Test that failures are correctly reported with singlecollect mode."""
         p1 = pytester.makepyfile(
@@ -54,7 +54,7 @@ def test_fail():
         result = pytester.runpytest(p1, "-n2", "--dist=singlecollect", "-v")
         assert result.ret == 1
         result.stdout.fnmatch_lines(["*1 failed*"])
-        
+
     def test_singlecollect_handles_fixtures(self, pytester: pytest.Pytester) -> None:
         """Test that fixtures work correctly with singlecollect mode."""
         pytester.makepyfile(

testing/test_dsession.py

@@ -482,22 +482,22 @@ def test_add_node_and_collection(self, pytester: pytest.Pytester) -> None:
         config = pytester.parseconfig("--tx=2*popen")
         sched = SingleCollectScheduling(config)
         node1, node2 = MockNode(), MockNode()
-        
+
         # First node should be set as collector
         sched.add_node(node1)
         assert sched.first_node == node1
-        
+
         # Second node should not become the collector
         sched.add_node(node2)
         assert sched.first_node == node1
-        
+
         # Collection from first node should be used
         collection = ["a.py::test_1", "a.py::test_2", "a.py::test_3"]
         sched.add_node_collection(node1, collection)
         assert sched.collection == collection
         assert sched.collection_done
         assert sched.collection_is_completed
-        
+
         # Collection from second node should be ignored
         different_collection = ["a.py::test_1", "a.py::test_4"]
         sched.add_node_collection(node2, different_collection)
@@ -510,21 +510,21 @@ def test_schedule_tests(self, pytester: pytest.Pytester) -> None:
         node1, node2 = MockNode(), MockNode()
         sched.add_node(node1)
         sched.add_node(node2)
-        
+
         collection = ["a.py::test_1", "a.py::test_2", "a.py::test_3", "a.py::test_4"]
         sched.add_node_collection(node1, collection)
-        
+
         # Should use collection from node1 and distribute tests
         sched.schedule()
-        
+
         # Check that tests were distributed across both nodes
         assert len(node1.sent) > 0
         assert len(node2.sent) > 0
-        
+
         # Tests should be distributed completely
         all_tests = node1.sent + node2.sent
         assert sorted(all_tests) == list(range(len(collection)))
-        
+
         # The pending list should be empty after distribution
         assert not sched.pending
 
@@ -534,37 +534,37 @@ def test_handle_node_failure(self, pytester: pytest.Pytester) -> None:
         node1, node2 = MockNode(), MockNode()
         sched.add_node(node1)
         sched.add_node(node2)
-        
+
         collection = ["a.py::test_1", "a.py::test_2", "a.py::test_3", "a.py::test_4"]
         sched.add_node_collection(node1, collection)
         sched.schedule()
-        
+
         # Simulate node1 completing a test
         test_idx = node1.sent[0]
         sched.mark_test_complete(node1, test_idx)
-        
+
         # Now remove node2 (simulating failure)
         crashitem = sched.remove_node(node2)
-        
+
         # Tests assigned to node2 should go back to pending
         assert len(sched.pending) > 0
-        
+
         # Add a new node
         node3 = MockNode()
         sched.add_node(node3)
-        
+
         # Since collection is already completed, schedule should assign pending tests to node3
         sched.schedule()
         assert len(node3.sent) > 0
-        
+
         # Complete all tests
         for idx in node1.sent:
             if idx != test_idx:  # Skip the one we already completed
                 sched.mark_test_complete(node1, idx)
-        
+
         for idx in node3.sent:
             sched.mark_test_complete(node3, idx)
-            
+
         # All tests should be completed
         assert sched.tests_finished
 
@@ -573,25 +573,25 @@ def test_first_node_failure(self, pytester: pytest.Pytester) -> None:
         config = pytester.parseconfig("--tx=2*popen")
         sched = SingleCollectScheduling(config)
         node1, node2 = MockNode(), MockNode()
-        
+
         # First node should be collector
         sched.add_node(node1)
         assert sched.first_node == node1
-        
+
         # Add second node
         sched.add_node(node2)
-        
+
         # First node fails before collection
         sched.remove_node(node1)
-        
+
         # Now second node should become the collector
         assert sched.first_node is None  # first_node is reset after removal
-        
+
         # Add a new node, it should become the collector
         node3 = MockNode()
         sched.add_node(node3)
         assert sched.first_node == node3
-        
+
         # Complete collection with node3
         collection = ["a.py::test_1", "a.py::test_2"]
         sched.add_node_collection(node3, collection)