async_btree.parallele.parallele() - Code Metrics - Inspection of "Merge pull request #3 from geronimo-iia/develop" - geronimo-iia/async-btree - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( d5e257...2cfe0f )

by Guibert

created 2019-07-03 02:52 UTC

async_btree.parallele.parallele() A

↳ Parent: async_btree.parallele

Complexity

Conditions

Size

Total Lines	32
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	10
dl	0
loc	32
rs	9.9
c	0
b	0
f	0
cc	3
nop	2

"""Curiosity module define special construct with curio framework."""

from typing import List

from .definition import (
    FAILURE,
    SUCCESS,
    AsyncInnerFunction,
    CallableFunction,
    node_metadata,
)
from .utils import amap


__all__ = ['parallele']


try:
    from curio import gather, spawn

    def parallele(
        children: List[CallableFunction], succes_threshold: int = -1
    ) -> AsyncInnerFunction:
        """
        Return an awaitable function which run children in parallele.

        succes_threshold generalize traditional sequence/fallback.
        succes_threshold must be in [0, len(children)],
            default value is len(children)

        if #success = succes_threshold, return a success

        if #failure = len(children) - succes_threshold, return a failure

        :param children: list of Awaitable
        :param succes_threshold: succes threshold value
        :return: an awaitable function.

        """
        succes_threshold = succes_threshold if succes_threshold else len(children)
        assert 0 <= succes_threshold <= len(children)

        @node_metadata(properties=['succes_threshold'])
        async def _parallele():

            results = await gather([task async for task in amap(spawn, children)])

            success = len(list(filter(bool, results)))

            return SUCCESS if success >= succes_threshold else FAILURE

        return _parallele


except Exception:  # pylint: disable=broad-except

    # default to a simple sequence
    from .control import sequence as parallele


1			"""Curiosity module define special construct with curio framework."""
2
3			from typing import List
4
5			from .definition import (
6			FAILURE,
7			SUCCESS,
8			AsyncInnerFunction,
9			CallableFunction,
10			node_metadata,
11			)
12			from .utils import amap
13
14
15			__all__ = ['parallele']
16
17
18			try:
19			from curio import gather, spawn
20
21			def parallele(
22			children: List[CallableFunction], succes_threshold: int = -1
23			) -> AsyncInnerFunction:
24			"""
25			Return an awaitable function which run children in parallele.
26
27			succes_threshold generalize traditional sequence/fallback.
28			succes_threshold must be in [0, len(children)],
29			default value is len(children)
30
31			if #success = succes_threshold, return a success
32
33			if #failure = len(children) - succes_threshold, return a failure
34
35			:param children: list of Awaitable
36			:param succes_threshold: succes threshold value
37			:return: an awaitable function.
38
39			"""
40			succes_threshold = succes_threshold if succes_threshold else len(children)
41			assert 0 <= succes_threshold <= len(children)
42
43			@node_metadata(properties=['succes_threshold'])
44			async def _parallele():
45
46			results = await gather([task async for task in amap(spawn, children)])
47
48			success = len(list(filter(bool, results)))
49
50			return SUCCESS if success >= succes_threshold else FAILURE
51
52			return _parallele
53
54
55			except Exception: # pylint: disable=broad-except
56
57			# default to a simple sequence
58			from .control import sequence as parallele
59

geronimo-iia / async-btree

Push — master ( d5e257...2cfe0f )

async_btree.parallele.parallele() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like