raygeo.pipeline.execute

Pipeline execution entry point.

Pipeline

cache_budget_bytes

cache_budget_bytes: int

Configured byte budget.

cache_used_bytes

cache_used_bytes: int

Current bytes in use by the cache.

clear_cache()

clear_cache() -> None

Clear the entire cache.

Parameter	Type	Description
Returns	None

clear_cache_prefix()

clear_cache_prefix(prefix: str) -> None

Clear all entries whose tag starts with prefix.

Parameter	Type	Description
prefix	str
Returns	None

execute()

execute(
    nodes: Sequence[request.NodeRequest],
    on_completed: Any,
    on_batch_progress: Optional[Any],
) -> None

Run all nodes in a single rayon::scope.

Parameter	Type	Description
nodes	Sequence[request.NodeRequest]	List of ~raygeo.pipeline.request.NodeRequest instances.
on_completed	Any	Callable (node: CompletedNode) -> None fired for every node.
on_batch_progress	Optional[Any]	Optional callable (fraction: float, message: str) -> None.
Returns	None

Functions

clear_cache()

clear_cache() -> None

Parameter	Type	Description
Returns	None

execute_stages()

execute_stages(
    nodes: list[pipeline.request.NodeRequest],
    on_completed: Callable[[pipeline.completed.CompletedNode], None],
    on_batch_progress: Callable[[float, str], None] | None = None,
) -> None

Run all nodes in a single rayon::scope.

Fires on_completed for every node (success, failure, or cancellation) with a CompletedNode carrying the node's key, generation_id, and either output or error. on_batch_progress (optional) fires with the aggregate fraction and a status message on every per-node progress report and every completion.

Parameter	Type	Description
nodes	list[pipeline.request.NodeRequest]
on_completed	Callable[[pipeline.completed.CompletedNode], None]
on_batch_progress	Callable[[float, str], None] | None = None
Returns	None