etha.tensor_bus.pair_state

State.

Classes

PairState

Runtime state of a registered Pair, held in-memory on the Agent.

Module Contents

class etha.tensor_bus.pair_state.PairState

Runtime state of a registered Pair, held in-memory on the Agent.

Created once per pair via register_pair(). Holds live process-group handles and the shape-independent M2M topology; never crosses a process boundary (the Agent only exposes scalar signals to the Client over LMDB).

local_group: torch.distributed.ProcessGroup

local_is_first: bool

local_name: str

local_ranks: list[int]

m2m_recv: etha.comm.ir.M2MMap | None = None

m2m_send: etha.comm.ir.M2MMap | None = None

pair_group: torch.distributed.ProcessGroup

pair_name: str

pair_size: int

remote_name: str

remote_ranks: list[int]

source_partial_groups: list[tuple[torch.distributed.ProcessGroup, str]] | None = None