Résultats partagés - Ajouter et conserver les résultats dans une base de données partagée

class manta_light.results.Results(host: str, port: int, swarm_id: PairId, task_id: PairId, chunk_size: int = 1048576)

Classe permettant d’accéder aux résultats de la base de données partagée ou d’ajouter des résultats dans la base de données partagée

Paramètres:

  • host (str) – Adresse du Manager

  • port (int) – Port du Manager

  • swarm_id (PairId) – Swarm ID

  • task_id (PairId) – ID de la tâche

  • chunk_size (int) – Taille du chunk

select(tag: str, size: int = -1, method: ResultMethod = ResultMethod.ALL)

Obtenir les résultats d’une tâche

Paramètres:

  • tag (str) – Le tag du résultat à obtenir

  • size (int, optional) – Le nombre de résultats à obtenir

  • method (ResultMethod, optional) – Méthode à utiliser pour sélectionner les résultats

Renvoie:

La réponse du service world

Type renvoyé:

dict

Exemples

À l’intérieur d’une classe Task, vous pouvez sélectionner des résultats stockés dans la base de données du Manager à partir de l’attribut self.world créé automatiquement par Task:

>>> params = self.world.results.select("model_params")
add(tag: str, result: dict)

Définir le résultat d’une tâche

Paramètres:

  • tag (str) – Le tag du résultat à définir

  • result (dict) – Le résultat à définir

Exemples

À l’intérieur d’une classe Task, vous pouvez ajouter des résultats à stocker dans la base de données du Manager à partir de l’attribut self.world créé automatiquement par Task:

>>> self.world.results.add("metrics", metrics)
async async_select(tag: str, size: int, method: ResultMethod) → dict

Obtenez les résultats des tâches

Paramètres:

  • tag (str) – Tag du résultat à obtenir

  • size (int) – Nombre de résultats à obtenir

  • method (str) – La méthode à utiliser pour sélectionner les résultats

Renvoie:

Réponse du service world

Type renvoyé:

dict

Exemples

Identique à select mais asynchrone:

>>> params = await self.world.results.async_select("model_params")
async async_add(tag: str, result: dict)

Définir le résultat d’une tâche

Paramètres:

  • tag (str) – Tag du résultat à définir

  • result (dict) – Résultat à ajouter

Exemples

Identique à select mais asynchrone:

>>> await self.world.results.async_add("metrics", metrics)