§ &`ƒikãóv—ddlmZddlmZddlZddlmZeGd„d¦«¦«ZGd„d¦«ZdS) é)Ú dataclass)ÚListN)ÚBackendcó2—eZdZUdZeed<eed<eed<dS)Ú Communicatorz= A handle to a communicator that we are a member of. ÚnameÚrankÚbackendN)Ú__name__Ú __module__Ú __qualname__Ú__doc__ÚstrÚ__annotations__Úint©óú|/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/experimental/collective/communicator.pyrrs9€€€€€€ððð €I€IIà €I€IIð€L€LL€L€LrrcóÚ—eZdZdZdeejjdedefd„Z dejjfd„Z e deejjfd „¦«Z e defd „¦«Z e defd „¦«Zd S) ÚCommunicatorHandlezj A communicator handle used by the driver to store handles to the actors in the communicator. Úactorsrr cóJ—||_||_t|¦«|_dS)a„ Initializes the CommunicatorHandle with the given actor handles. Assumes that the communicator has already been initialized on all actors. Args: actors: A list of actor handles to be stored. name: Name of the communicator. backend: Communicator backend. See ray.util.collective.types for valid values. N)Ú_actorsÚ_namerÚ_backend)Úselfrrr s rÚ__init__zCommunicatorHandle.__init__s%€ðˆŒ ؈Œ Ý Ñ(Ô(ˆŒ ˆ ˆ rÚactorcóN—t|j¦«D]\}}||kr|cSŒdS)Néÿÿÿÿ)Ú enumerater)rrÚiÚas rÚget_rankzCommunicatorHandle.get_rank,s;€Ý˜dœlÑ+Ô+ð ð ‰DˆAˆqØEŠzˆzØðàˆrrÚreturncó —|jdd…S)z@ Return all actor handles in this communicator. N)r©rs rrzCommunicatorHandle.actors2s€ð Œ|˜A˜A˜AŒÐrcó—|jS©N)rr's rrzCommunicatorHandle.name9s €àŒzÐrcó—|jSr))rr's rr zCommunicatorHandle.backend=s €àŒ}ÐrN)r r r rrÚrayrÚ ActorHandlerrr$Úpropertyrrr rrrrrsñ€€€€€ððð )˜t C¤IÔ$9Ô:ð )À#ð )ÐPSð )ð )ð )ð )ð˜cœiÔ3ððððð ð˜˜SœYÔ2Ô3ðððñ„Xðð ðcðððñ„Xððð˜ðððñ„Xðððrr) Ú dataclassesrÚtypingrr+Úray.util.collective.typesrrrrrrúr1sªðØ!Ð!Ð!Ð!Ð!Ð!ØÐÐÐÐÐà € € € Ø-Ð-Ð-Ð-Ð-Ð-ð ð ð ð ð ð ñ ô ñ „ð ð(ð(ð(ð(ð(ñ(ô(ð(ð(ð(r