src.utils.task_manager.blocking.clustering

Attributes

logger

Functions

update_database_clustering_result(embedding_result_id, ...)	Callback function to update the database upon task completion.
_get_embedding_results(dataset_name)
_get_pickled_embeddings(dataset_id, embedding_id)
compute_clusters(dataset_name, list_clustering_methods)

Module Contents

src.utils.task_manager.blocking.clustering.logger

src.utils.task_manager.blocking.clustering.update_database_clustering_result(embedding_result_id: int, clustering_method: str, filepath: str | os.PathLike, task_state: str, task_key: str = None)

Callback function to update the database upon task completion.

src.utils.task_manager.blocking.clustering._get_embedding_results(dataset_name)

src.utils.task_manager.blocking.clustering._get_pickled_embeddings(dataset_id, embedding_id)

src.utils.task_manager.blocking.clustering.compute_clusters(dataset_name, list_clustering_methods)