Module rio_tiler.tasks

rio_tiler.tasks: tools for handling rio-tiler's future tasks.

Variables

MAX_THREADS

TaskType

Functions

create_tasks

def create_tasks(
    reader: Callable,
    asset_list: Sequence,
    threads: int,
    *args,
    **kwargs
) -> Sequence[Tuple[Union[concurrent.futures._base.Future, Callable], Any]]

Create Future Tasks.

filter_tasks

def filter_tasks(
    tasks: Sequence[Tuple[Union[concurrent.futures._base.Future, Callable], Any]],
    allowed_exceptions: Union[Tuple, NoneType] = None
) -> Generator

Filter Tasks to remove Exceptions.

Parameters:

Name	Type	Description	Default
tasks	sequence	Sequence of 'concurrent.futures._base.Future' or 'Callable'	None
allowed_exceptions	tuple	List of exceptions which won't be raised.	None

Yields:

Type	Description
None	Task results.

multi_arrays

def multi_arrays(
    asset_list: Sequence,
    reader: Callable[..., rio_tiler.models.ImageData],
    *args: Any,
    threads: int = 10,
    allowed_exceptions: Union[Tuple, NoneType] = None,
    **kwargs: Any
) -> rio_tiler.models.ImageData

Merge arrays returned from tasks.

multi_points

def multi_points(
    asset_list: Sequence,
    reader: Callable[..., rio_tiler.models.PointData],
    *args: Any,
    threads: int = 10,
    allowed_exceptions: Union[Tuple, NoneType] = None,
    **kwargs: Any
) -> rio_tiler.models.PointData

Merge points returned from tasks.

multi_values

def multi_values(
    asset_list: Sequence,
    reader: Callable,
    *args: Any,
    threads: int = 10,
    allowed_exceptions: Union[Tuple, NoneType] = None,
    **kwargs: Any
) -> Dict

Merge values returned from tasks.