Function test_simple_concurrency

tests/test_tar_upload_pool.py:55–62

Try a pool that cannot execute all submitted jobs at once.

()

def test_simple_concurrency():
    """Try a pool that cannot execute all submitted jobs at once."""
    pool = make_pool(1, 1)

    for i in range(3):
        pool.put(FakeTarPartition(1))

    pool.join()


def test_fault_midstream():