e736c0beee25584bbb7310c369c97b11b88ec8dc,distributed/tests/test_semaphore.py,,test_release_retry,#Any#Any#Any#Any#,528

Before Change

    Verify that we can properly retry a semaphore release operation
    with dask.config.set({"distributed.comm.retry.count": 1}):
        pool = await FlakyConnectionPool(failing_connections=1)
        rpc = pool(s.address)
        c.scheduler = rpc
        semaphore = await Semaphore(
            max_leases=2, name="resource_we_want_to_limit", client=c
        )
        await semaphore.acquire()
        pool.activate()  // Comm chaos starts
        with captured_logger("distributed.utils_comm") as caplog:
            assert await semaphore.release() is True

After Change

    with dask.config.set({"distributed.comm.retry.count": 1}):
        pool = await FlakyConnectionPool(failing_connections=1)

        semaphore = await Semaphore(
            max_leases=,
            name="resource_we_want_to_limit",
            scheduler_rpc=pool(s.address),
        )
        await semaphore.acquire()
        pool.activate()  // Comm chaos starts

Instances