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

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

Service World pour accéder aux valeurs avec d’autres nœuds

Le service World permet à l’utilisateur d’interagir avec des valeurs collectives lors d’une itération Swarm

Les paramètres ne doivent pas être remplis manuellement. Ils sont gérés automatiquement lors du déploiement de la tâche par le Node.

Paramètres:

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

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

  • swarm_id (Optional[PairId]) – Swarm ID

  • task_id (Optional[PairId]) – 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

Depuis l’attribut Task :

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

Arrêter le Swarm

Exemples

Depuis 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êter le Swarm

Exemples

Identique à stop_swarm mais asynchrone :

>>> await self.world.async_stop_swarm()