Monde - Accéder aux valeurs et planifier les itérations

class manta_light.world.World(host: str | None = None, port: int | None = None, task_id: str | None = None)

Service mondial d’accès aux valeurs avec d’autres nœuds

Le service World permet à l’utilisateur d’interagir avec des collectifsvaleurs pendant une itération Swarm

Les paramètres ne doivent pas être remplis manuellement. Au lieu de cela, ils sont gérés pendantle déploiement de la tâche par le Node.

Paramètres:

  • host (Optional[str]) – Adresse du Manager

  • port (Optional[int]) – Port du Manager

  • task_id (Optional[str]) – ID de la tâche

schedule_next_iter(node_ids: list, task_to_schedule_alias: str)

Planifier la prochaine itération

Paramètres:

  • node_ids (list) – La liste des identifiants de nœuds pour lesquels planifier la prochaine itération

  • task_to_schedule_alias (str) – La tâche à planifier pour la prochaine itération

Exemples

De l’attribut Task :

>>> self.world.schedule_next_iter(
...     node_ids=selected_nodes, task_to_schedule_alias="worker"
... )
stop_swarm()

Arrêtez du Swarm

Exemples

De l’attribut Task :

>>> self.world.stop_swarm()
async async_schedule_next_iter(node_ids: list, task_to_schedule_alias: str)

Planifier la prochaine itération

Paramètres:

  • node_ids (list) – La liste des identifiants de nœuds pour lesquels planifier la prochaine itération

  • task_to_schedule_alias (str) – La tâche à planifier pour la prochaine itération

Exemples

Identique à schedule_next_iter mais asynchrone :

>>> await self.world.async_schedule_next_iter(
...     node_ids=selected_nodes, task_to_schedule_alias="worker"
... )
async async_stop_swarm()

Arrêtez du Swarm

Exemples

Identique à stop_swarm maisasynchrone:

>>> await self.world.async_stop_swarm()