Skip to content

rio_tiler.tasks

rio_tiler.tasks

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

create_tasks 

create_tasks(reader: Callable, asset_list: Sequence, threads: int, *args, **kwargs) -> TaskType

Create Future Tasks.

filter_tasks 

filter_tasks(tasks: TaskType, allowed_exceptions: Optional[Tuple] = None) -> Generator

Filter Tasks to remove Exceptions.

Parameters:

  • tasks (sequence) –

    Sequence of 'concurrent.futures._base.Future' or 'Callable'

  • allowed_exceptions (tuple, default: None ) –

    List of exceptions which won't be raised.

Yields:

multi_arrays 

multi_arrays(asset_list: Sequence, reader: Callable[..., ImageData], *args: Any, threads: int = MAX_THREADS, allowed_exceptions: Optional[Tuple] = None, **kwargs: Any) -> ImageData

Merge arrays returned from tasks.

multi_points 

multi_points(asset_list: Sequence, reader: Callable[..., PointData], *args: Any, threads: int = MAX_THREADS, allowed_exceptions: Optional[Tuple] = None, **kwargs: Any) -> PointData

Merge points returned from tasks.

multi_values 

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

Merge values returned from tasks.