dask / distributed

A distributed task scheduler for Dask
https://distributed.dask.org
BSD 3-Clause "New" or "Revised" License
1.57k stars 718 forks source link

pytest-xdist is not being ignored in code samples #8602

Open crusaderky opened 6 months ago

crusaderky commented 6 months ago

The xdist module has been in the code capture ignorelist since #8290. However, this is from the most recent coiled/benchmarks run:

Span test_query_1 in /home/runner/miniconda3/envs/test/lib/python3.12/site-packages/xdist/remote.py
    def run_one_test(self):
        self.item_index = self.nextitem_index
        self.nextitem_index = self._get_next_item_index()

        items = self.session.items
        item = items[self.item_index]
        if self.nextitem_index is self.SHUTDOWN_MARK:
            nextitem = None
        else:
            nextitem = items[self.nextitem_index]

        worker_title("[pytest-xdist running] %s" % item.nodeid)

        start = time.time()
        self.config.hook.pytest_runtest_protocol(item=item, nextitem=nextitem)
        duration = time.time() - start

        worker_title("[pytest-xdist idle]")

        self.sendevent(
            "runtest_protocol_complete", item_index=self.item_index, duration=duration
        )
Span test_query_1 in /home/runner/work/benchmarks/benchmarks/tests/tpch/test_dask.py
@pytest.mark.shuffle_p2p
def test_query_1(client, dataset_path, fs, scale):
    dask_queries.query_1(dataset_path, fs, scale).compute()