streamsight.registries.AlgorithmStatusRegistry

class streamsight.registries.AlgorithmStatusRegistry

Bases: object

Registry for algorithm status.

This registry is used to store the status of the algorithms. The status of the algorithms are stored in the registry and can be accessed by the user. The status of the algorithms are used to keep track of the state of the algorithms.

The registry uses the AlgorithmStatusEntry to store the status of the algorithms. The registry allows the user to update the status of the algorithms and get the status of the algorithms.

The recommended way to use this registry is to use provided function update() to update the status of the algorithms. Aggregating the status of the algorithms can be done by using the all_algo_states() function.

__init__()

Methods

__init__()
all_algo_states()
get(algo_id)
get_algorithm_identifier(algo_id)
is_all_predicted()
is_all_same_data_segment()
register(algo_id, entry)
set_all_ready(data_segment)
update(algo_id, state[, data_segment])

all_algo_states() → Dict[str, AlgorithmStateEnum]

get(algo_id: UUID) → AlgorithmStatusEntry

get_algorithm_identifier(algo_id: UUID) → str

is_all_predicted() → bool

is_all_same_data_segment() → bool

register(algo_id: UUID, entry: AlgorithmStatusEntry) → None

set_all_ready(data_segment: int) → None

update(algo_id: UUID, state: AlgorithmStateEnum, data_segment: int | None = None) → None