async_btree.parallele.parallele()

Complexity

Conditions

3

Size

Total Lines	32
Code Lines	10

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

"""Curiosity module define special construct with curio framework."""
    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