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:

Generator –

Task results.

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.

multi_values_list ¶

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

Merge values returned from tasks.