def test_simple_concurrency():
    pool = make_pool(1, 1)

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

    pool.join()
Try a pool that cannot execute all submitted jobs at once.
dataset/ETHPy150Open wal-e/wal-e/tests/test_tar_upload_pool.py/test_simple_concurrency