tests.test_parallele

Complexity

Total Complexity

4

Size/Duplication

Total Lines	27
Duplicated Lines	0 %

Importance

Changes

0

4 Functions

Rating	Name	Duplication	Size	Complexity
A	b_func()	0	3	1
A	a_func()	0	3	1
A	test_parallele()	0	6	1
A	failure_func()	0	3	1

from curio import sleep

from async_btree import FAILURE, parallele


async def a_func():
    await sleep(1)
    return 'a'


async def b_func():
    await sleep(3)
    return 'b'


async def failure_func():
    await sleep(2)
    return FAILURE


def test_parallele(kernel):
    assert kernel.run(parallele(children=[a_func]))
    assert kernel.run(parallele(children=[a_func, b_func]))
    assert not kernel.run(parallele(children=[a_func, b_func, failure_func]))
    assert kernel.run(
        parallele(children=[a_func, b_func, failure_func], succes_threshold=2)
    )