wait

wait(waitables: Sequence[Waitable], num_returns: int | None = None, timeout: float | None = None) -> tuple[list[Waitable], list[Waitable]]

Attend que les waitables se terminent et renvoie (done, pending). Chaque type de waitable possède son propre comportement d’attente :

Sandbox : attend jusqu’au statut RUNNING
OperationRef : attend la fin de l’opération
Process : attend la fin du processus Paramètres
waitables (Sequence[Waitable]) : séquence d’objets Sandbox, OperationRef ou Process.
num_returns (int | None) : si spécifié, renvoie dès que ce nombre d’éléments est terminé. Si None, attend que tous soient terminés.
timeout (float | None) : durée d’attente maximale, en secondes. Si None, attend indéfiniment.

Renvoie

tuple[list[Waitable], list[Waitable]] : tuple de listes (done, pending) contenant les objets waitables originaux.

Exceptions levées

Exemples Attendre que tous les bacs à sable soient en cours d’exécution :

sandboxes = [Sandbox.run(...) for _ in range(5)]
done, pending = cwsandbox.wait(sandboxes)

Attendre la fin des 2 premières opérations :

refs = [sb.read_file(f) for f in files]
done, pending = cwsandbox.wait(refs, num_returns=2)

Attendre avec un délai d’expiration :

done, pending = cwsandbox.wait(procs, timeout=30.0)