Integrate isoscope scheduling and distributed sccope isolation into xdist. Not tested yet.

Author: vkruglik-aka

CHANGELOG.rst

@@ -1,3 +1,10 @@
+pytest-xdist 3.7.zzz (2024-zz-zz)
+===============================
+
+Features
+--------
+- ZZZ Describe addition of isoscope scheduler
+
 pytest-xdist 3.6.1 (2024-04-28)
 ===============================
 

docs/distribution.rst

@@ -49,6 +49,19 @@ The test distribution algorithm is configured with the ``--dist`` command-line o
 
 .. _distribution modes:
 
+* ``--dist isoscope``: Scope Isolation Scheduler. Tests are grouped by module for
+  test functions and by class for test methods. Tests are executed one group at a
+  time, distributed across available workers. This groupwise isolation guarantees
+  that all tests in one group complete execution before running another group of
+  tests. This can be useful when module-level or class-level fixtures of one group
+  could create undesirable side-effects for tests in other test groups, while
+  taking advantage of distributed execution of tests within each group. Grouping
+  by class takes priority over grouping by module. NOTE: the use of this scheduler
+  requires distributed coordination for setup and teardown such as provided by
+  the ``iso_scheduling`` fixture or an alternate implementation of distributed
+  coordination - see the ``iso_scheduling.coordinate_setup_teardown`` usage example
+  in iso_scheduling_plugin.py.
+
 * ``--dist load`` **(default)**: Sends pending tests to any worker that is
   available, without any guaranteed order. Scheduling can be fine-tuned with
   the `--maxschedchunk` option, see output of `pytest --help`.

pyproject.toml

@@ -34,6 +34,7 @@ classifiers = [
 requires-python = ">=3.8"
 dependencies = [
     "execnet>=2.1",
+    "filelock>=3.13.1",
     "pytest>=7.0.0",
 ]
 dynamic = ["version"]
@@ -47,6 +48,7 @@ Tracker = "https://github.com/pytest-dev/pytest-xdist/issues"
 
 [project.entry-points.pytest11]
 xdist = "xdist.plugin"
+"xdist.iso_scheduling_plugin" = "xdist.iso_scheduling_plugin"
 "xdist.looponfail" = "xdist.looponfail"
 
 [project.optional-dependencies]

src/xdist/dsession.py

@@ -15,6 +15,7 @@
 from xdist.remote import Producer
 from xdist.remote import WorkerInfo
 from xdist.scheduler import EachScheduling
+from xdist.scheduler import IsoScopeScheduling
 from xdist.scheduler import LoadFileScheduling
 from xdist.scheduler import LoadGroupScheduling
 from xdist.scheduler import LoadScheduling
@@ -113,6 +114,8 @@ def pytest_xdist_make_scheduler(
         dist = config.getvalue("dist")
         if dist == "each":
             return EachScheduling(config, log)
+        if dist == "isoscope":
+            return IsoScopeScheduling(config, log)
         if dist == "load":
             return LoadScheduling(config, log)
         if dist == "loadscope":

src/xdist/iso_scheduling_plugin.py

@@ -22,9 +22,9 @@
 #  OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 # SOFTWARE.
 
-"""Pytest Fixtures for supporting the PARALLEL_MONO_SCOPE Test Distribution Mode.
+"""Pytest Fixtures for supporting users of isoscope scheduling.
 
-NOTE: These fixtures are NOT compatible with any other Test Distribution Modes.
+NOTE: These fixtures are NOT compatible with any other xdist schedulers.
 
 NOTE: DO NOT IMPORT this module. It needs to be loaded via pytest's
 `conftest.pytest_plugins` mechanism. Pytest doc discourages importing fixtures
@@ -46,8 +46,8 @@
 import filelock
 import pytest
 
-from utils.common.parallel_mono_scope_utils import (
-    ParallelMonoScopeFixture,
+from xdist.iso_scheduling_utils import (
+    IsoSchedulingFixture,
     DistributedSetupCoordinator,
     DistributedSetupContext,
     DistributedTeardownContext,
@@ -63,14 +63,13 @@
 
 
 @pytest.fixture(scope='session')
-def parallel_mono_scope(
+def iso_scheduling(
         tmp_path_factory: pytest.TempPathFactory,
         testrun_uid: str,
         worker_id: str
-        ) -> ParallelMonoScopeFixture:
+        ) -> IsoSchedulingFixture:
     """A session-scoped pytest fixture for coordinating setup/teardown of test
-    scope/class which is executing in the parallel_mono_scope Test Distribution
-    Mode.
+    scope/class which is executing under isoscope scheduling.
 
     NOTE: Each XDist remote worker is running its own Pytest Session.
 
@@ -82,24 +81,23 @@ def parallel_mono_scope(
         import pytest
 
         if TYPE_CHECKING:
-            from utils.common.parallel_mono_scope_utils import (
-                ParallelMonoScopeFixture,
+            from xdist.iso_scheduling_utils import (
+                IsoSchedulingFixture,
                 DistributedSetupContext,
                 DistributedTeardownContext
             )
 
-        @pytest.mark.parallel_mono_scope
-        class TestDeng12345ParallelMonoScope:
+        class TestSomething:
 
             @classmethod
             @pytest.fixture(scope='class', autouse=True)
             def distributed_setup_and_teardown(
                     cls,
-                    parallel_mono_scope: ParallelMonoScopeFixture:
+                    iso_scheduling: IsoSchedulingFixture:
                     request: pytest.FixtureRequest):
 
                 # Distributed Setup and Teardown
-                with parallel_mono_scope.coordinate_setup_teardown(
+                with iso_scheduling.coordinate_setup_teardown(
                         setup_request=request) as coordinator:
                     # Distributed Setup
                     coordinator.maybe_call_setup(cls.patch_system_under_test)
@@ -126,12 +124,13 @@ def revert_system_under_test(
                 # Fetch state from `teardown_context.client_dir` and revert
                 # changes made by `patch_system_under_test()`.
 
-            perms, tc_ids = generate_tests(
-                os.path.realpath(__file__),
-                TestDistributionModeEnum.PARALLEL_MONO_SCOPE)
+            def test_case1(self)
+                ...
+
+            def test_case2(self)
+                ...
 
-            @pytest.mark.parametrize('test_data', perms, ids=tc_ids)
-            def test_case(self, test_data: dict[str, dict])
+            def test_case3(self)
                 ...
         ```
 
@@ -146,17 +145,17 @@ def test_case(self, test_data: dict[str, dict])
         yields an instance of `DistributedSetupCoordinator` for the current
         Pytest Session.
     """
-    return _ParallelMonoScopeFixtureImpl(tmp_path_factory=tmp_path_factory,
-                                         testrun_uid=testrun_uid,
-                                         worker_id=worker_id)
+    return _IsoSchedulingFixtureImpl(tmp_path_factory=tmp_path_factory,
+                                     testrun_uid=testrun_uid,
+                                     worker_id=worker_id)
 
 
-class _ParallelMonoScopeFixtureImpl(ParallelMonoScopeFixture):
+class _IsoSchedulingFixtureImpl(IsoSchedulingFixture):
     """Context manager yielding a new instance of the implementation of the
     `DistributedSetupCoordinator` interface.
 
-    An instance of _ParallelMonoScopeFixtureImpl is returned by our pytest
-    fixture `parallel_mono_scope`.
+    An instance of _IsoSchedulingFixtureImpl is returned by our pytest
+    fixture `iso_scheduling`.
     """
     # pylint: disable=too-few-public-methods
 
@@ -206,11 +205,11 @@ def coordinate_setup_teardown(
 
 
 class _DistributedSetupCoordinatorImpl(DistributedSetupCoordinator):
-    """Distributed scope/class setup/teardown coordination for the
-    `parallel_mono_scope` Test Distribution Mode.
+    """Distributed scope/class setup/teardown coordination for isoscope
+    scheduling.
 
     NOTE: do not instantiate this class directly. Use the
-    `parallel_mono_scope` fixture instead!
+    `iso_scheduling` fixture instead!
 
     """
     _DISTRIBUTED_SETUP_ROOT_DIR_LINK_NAME = 'distributed_setup'
@@ -257,7 +256,7 @@ def maybe_call_setup(
         Process-safe.
 
         Call `maybe_call_setup` from the pytest setup-teardown fixture of your
-        `PARALLEL_MONO_SCOPE` test (typically test class) if it needs to
+        isoscope-scheduled test (typically test class) if it needs to
         initialize a resource which is common to all of its test cases which may
         be executing in different XDist worker processes (such as a subnet in
         `subnet.xml`).
@@ -272,8 +271,7 @@ def maybe_call_setup(
         :return: An instance of `DistributedSetupContext` which MUST be passed
             in the corresponding call to `maybe_call_teardown`.
 
-        :raise parallel_mono_scope.CoordinationTimeoutError: If attempt to
-            acquire the lock times out.
+        :raise CoordinationTimeoutError: If attempt to acquire the lock times out.
         """
         # `maybe_call_setup()` may be called only once per instance of
         # `_SetupCoordinator`
@@ -307,7 +305,7 @@ def maybe_call_teardown(
         tests for your test scope. Process-safe.
 
         Call `maybe_call_teardown` from the pytest setup-teardown fixture of
-        your `PARALLEL_MONO_SCOPE` test (typically test class) if it needs to
+        your isoscope-scheduled test (typically test class) if it needs to
         initialize a resource which is common to all of its test cases which may
         be executing in different XDist worker processes (such as a subnet in
         `subnet.xml`).
@@ -320,8 +318,7 @@ def maybe_call_teardown(
             invoked.
         :param timeout: Lock acquisition timeout in seconds
 
-        :raise parallel_mono_scope.CoordinationTimeoutError: If attempt to
-            acquire the lock times out.
+        :raise CoordinationTimeoutError: If attempt to acquire the lock times out.
         """
         # Make sure `maybe_call_setup()` was already called on this instance
         # of `_SetupCoordinator`
@@ -359,8 +356,7 @@ def wrapper(*args, **kwargs):
 
 class _DistributedSetupCoordinationImpl:
     """Low-level implementation of Context Managers for Coordinating
-    Distributed Setup and Teardown for the `parallel_mono_scope`
-    Test Distribution Mode.
+    Distributed Setup and Teardown for users of isoscope scheduling.
     """
     _ROOT_STATE_FILE_NAME = 'root_state.json'
     _ROOT_LOCK_FILE_NAME = 'lock'
@@ -426,7 +422,7 @@ def acquire_distributed_setup(
             timeout: float
             ) -> Generator[DistributedSetupContext, None, None]:
         """Low-level implementation of Context Manager for Coordinating
-        Distributed Setup for the `parallel_mono_scope` Test Distribution Mode.
+        Distributed Setup for isoscope scheduling.
 
         :param root_context_dir: Scope/class-specific root directory for
             saving this context manager's state. This directory is common to
@@ -436,8 +432,7 @@ def acquire_distributed_setup(
             directly by the calling setup-teardown fixture.
         :param timeout: Lock acquisition timeout in seconds
 
-        :raise parallel_mono_scope.CoordinationTimeoutError: If attempt to
-            acquire the lock times out.
+        :raise CoordinationTimeoutError: If attempt to acquire the lock times out.
         """
         #
         # Before control passes to the managed code block
@@ -502,16 +497,14 @@ def acquire_distributed_teardown(
             timeout: float
             ) -> Generator[DistributedTeardownContext, None, None]:
         """Low-level implementation of Context Manager for Coordinating
-        Distributed Teardown for the `parallel_mono_scope` Test Distribution
-        Mode.
+        Distributed Teardown for the isoscope scheduling.
 
         :param setup_context: The instance of `DistributedSetupContext` that was
             yielded by the corresponding use of the
             `_distributed_setup_permission` context manager.
         :param timeout: Lock acquisition timeout in seconds
 
-        :raise parallel_mono_scope.CoordinationTimeoutError: If attempt to
-            acquire the lock times out.
+        :raise CoordinationTimeoutError: If attempt to acquire the lock times out.
         """
         #
         # Before control passes to the managed code block