o c²“iä ã @sÌddlmZmZmZddlZdedfdd„Zdddeedefdeeedefeedefffd d „Zd ed eedefdeeedefeedefffd d„Zdeddefdd„Z dS)é)ÚListÚOptionalÚTupleNÚreturnzray.actor.ActorHandlecCs"zt ¡jWStyYdSw)zv Get the current actor handle in this worker. If this is called in a driver process, it will return None. N)ÚrayÚget_runtime_contextÚ current_actorÚ RuntimeError©r r úR/home/ubuntu/.local/lib/python3.10/site-packages/ray/experimental/channel/utils.pyÚget_self_actors   ÿr ÚwriterÚreader_and_node_listcCsDg}g}|D]\}}||kr| ||f¡q| ||f¡q||fS)a\Split readers into remote and local readers based on writer. Args: writer: The actor handle of the writer reader_and_node_list: List of (reader, node) tuples Returns: Tuple containing: - List of (reader, node) tuples for remote readers - List of (reader, node) tuples for local readers ©Úappend)r rÚremote_readersÚ local_readersÚreaderÚnoder r r Úsplit_readers_by_localitys rrÚactor_and_node_listcCsDg}g}|D]\}}||kr| ||f¡q| ||f¡q||fS)a×Split actors into remote and local actors based on node. The local actors will be on the same node as the given node. The remote actors will be on a different node. Args: writer_node: The node of the writer actor_and_node_list: List of (actor, node) tuples Returns: Tuple containing: - List of (actor, node) tuples for actors on the same node - List of (actor, node) tuples for actors on a different node r)rrÚactors_on_same_nodeÚactors_on_different_nodeÚactorÚ actor_noder r r Úsplit_actors_by_node_locality.s rrcCs8|dus |t ¡jkrt ¡ ¡St |j dd„¡¡S)zƒGet the node of the actor. Args: actor: The actor handle of the actor Returns: The node of the actor NcSs t ¡ ¡S)N)rrÚ get_node_id)Úselfr r r ÚZs z get_actor_node..)rrrrÚgetÚ __ray_call__Úremote)rr r r Úget_actor_nodeLs ÿÿr") Útypingrrrrr Ústrrrr"r r r r Ús, ÿþÿ ýÿþÿ ý