
    i	                    F    S SK Jr  S SKrS SKJr  SSKJr   " S S\5      rg)    )annotationsN)Producer   )LoadScopeSchedulingc                  >   ^  \ rS rSrSrSSU 4S jjjrSS jrSrU =r$ )	LoadFileScheduling
   aK  Implement load scheduling across nodes, but grouping test test file.

This distributes the tests collected across all nodes so each test is run
just once.  All nodes collect and submit the list of tests and when all
collections are received it is verified they are identical collections.
Then the collection gets divided up in work units, grouped by test file,
and those work units get submitted to nodes.  Whenever a node finishes an
item, it calls ``.mark_test_complete()`` which will trigger the scheduler
to assign more work units if the number of pending tests for the node falls
below a low-watermark.

When created, ``numnodes`` defines how many nodes are expected to submit a
collection. This is used to know when all nodes have finished collection.

This class behaves very much like LoadScopeScheduling, but with a file-level scope.
c                n   > [         TU ]  X5        Uc  [        S5      U l        g UR                  U l        g )Nloadfilesched)super__init__r   logr   )selfconfigr   	__class__s      W/var/www/html/ai-image-ml/venv/lib/python3.13/site-packages/xdist/scheduler/loadfile.pyr   LoadFileScheduling.__init__   s.    %;0DH((DH    c                ,    UR                  SS5      S   $ )a  Determine the scope (grouping) of a nodeid.

There are usually 3 cases for a nodeid::

    example/loadsuite/test/test_beta.py::test_beta0
    example/loadsuite/test/test_delta.py::Delta1::test_delta0
    example/loadsuite/epsilon/__init__.py::epsilon.epsilon

#. Function in a test module.
#. Method of a class in a test module.
#. Doctest in a function in a package.

This function will group tests with the scope determined by splitting
the first ``::`` from the left. That is, test will be grouped in a
single work unit when they reside in the same file.

In the above example, scopes will be::

.. code-block:: text

    example/loadsuite/test/test_beta.py
    example/loadsuite/test/test_delta.py
    example/loadsuite/epsilon/__init__.py
z::r   r   )split)r   nodeids     r   _split_scopeLoadFileScheduling._split_scope#   s    2 ||D!$Q''r   )r   )N)r   zpytest.Configr   zProducer | NonereturnNone)r   strr   r   )	__name__
__module____qualname____firstlineno____doc__r   r   __static_attributes____classcell__)r   s   @r   r   r   
   s    ") )( (r   r   )
__future__r   pytestxdist.remoter   	loadscoper   r    r   r   <module>r)      s    "  ! *2(, 2(r   