Function test_gather_tasks_with_n_concurrency

tests/utils_test.py:17–21

()

@pytest.mark.asyncio
async def test_gather_tasks_with_n_concurrency():
    tasks = [asyncio.create_task(number_task(i)) for i in range(1000)]
    sum_value = (0 + 999) * 1000 / 2
    result = await gather_with_concurrency(10, tasks)
    assert sum_value == sum(result), 'the final sum value is not correct'


def test_fetch_metadata():