RendezvousHandler

class tensorplay.distributed.elastic.rendezvous.RendezvousHandler[source]

Algorithmic interface of one rendezvous backend.

abstractmethod get_backend() → str[source]

Backend name (e.g. static or core).

abstractmethod get_run_id() → str[source]

Run identifier of this rendezvous.

abstractmethod is_closed() → bool[source]

Whether the rendezvous has been marked closed.

abstractmethod next_rendezvous() → RendezvousInfo[source]

Join or re-join the rendezvous; blocks until this round completes.

abstractmethod num_nodes_waiting() → int[source]

Number of nodes queued for the next round (pending scale-up).

pre_shutdown() → None[source]

Optional hook invoked before shutdown() during agent teardown.

abstractmethod set_closed() → None[source]

Mark the rendezvous closed; new joiners are rejected.

abstractmethod shutdown() → bool[source]

Release rendezvous resources; returns True when the backend shut down.

property use_agent_store: bool

Whether workers can reuse the agent-held store as their bootstrap store.