&`i FddlmZmZmZddlZdedfdZdddeedefdeeedefeedefffdZd ed eedefdeeedefeedefffd Zd eddefd Z dS))ListOptionalTupleNreturnzray.actor.ActorHandlecV tjjS#t$rYdSwxYw)zv Get the current actor handle in this worker. If this is called in a driver process, it will return None. N)rayget_runtime_context current_actor RuntimeErrorr/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/experimental/channel/utils.pyget_self_actorrs; &((66 tts  ((writerreader_and_node_listcg}g}|D]:\}}||kr|||f#|||f;||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)rrremote_readers local_readersreadernodes rsplit_readers_by_localityrsm"NM,11  V    ! !64. 1 1 1 1  &$ 0 0 0 0 = ((r ractor_and_node_listcg}g}|D]:\}}||kr|||f#|||f;||fS)aSplit 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)rractors_on_same_nodeactors_on_different_nodeactor actor_nodes rsplit_actors_by_node_localityr .su$!0AAz :    & &z': ; ; ; ; $ + +UJ,? @ @ @ @  8 88r rc||tjjkr%tjStj|jdS)zGet the node of the actor. Args: actor: The actor handle of the actor Returns: The node of the actor NcLtjS)N)rr get_node_id)selfs rz get_actor_node..ZsS466BBDDr )rr r r#get __ray_call__remote)rs rget_actor_noder)Lsj }!8!:!:!HHH&((44666w   % %DD     r ) typingrrrrrstrrr r)r r rr,sW(((((((((( !89) #)u%