
    &`iS                     z    d dl mZmZmZmZmZ d dlZd dlmZ d dl	m
Z
 d dlmZ e G d de                      ZdS )    )AnyDictListTupleUnionN)DAGNodeget_dag_node_str)DeveloperAPIc            
            e Zd ZdZ	 ddeee         ee         f         dee	e
f         f fdZdeej        df         fdZd	ee
         d
ee	e
f         dee	e
f         dee	e
f         ddf
dZde	fdZ xZS )MultiOutputNodezARay dag node used in DAG building API to mark the endpoint of DAGNargsother_args_to_resolvec                    t          |t                    rt          |          }t          |t                    s t          dt	          |           d          t                                          |i i |pi            d S )NzInvalid input type for `args`, .)r   )
isinstancetuplelist
ValueErrortypesuper__init__)selfr   r   	__class__s      g/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/dag/output_node.pyr   zMultiOutputNode.__init__   s    
 dE"" 	::D$%% 	NLtDzzLLLMMM"7"=2	 	 	
 	
 	
 	
 	
    returnzray.actor.ActorHandlec                     | j         S N)_bound_args)r   r   kwargss      r   _execute_implzMultiOutputNode._execute_impl   s     r   new_args
new_kwargsnew_optionsnew_other_args_to_resolver   c                 "    t          ||          S )z3Return a copy of this node with the given new args.)r   )r   r#   r$   r%   r&   s        r   
_copy_implzMultiOutputNode._copy_impl"   s     x)BCCCr   c                 "    t          | d          S )N__MultiOutputNode__r	   )r   s    r   __str__zMultiOutputNode.__str__,   s    &;<<<r   r   )__name__
__module____qualname____doc__r   r   r   r   r   strr   r   ray	ObjectRefr"   r(   r+   __classcell__)r   s   @r   r   r   	   s&       KK
 15
 
DM5>12
  $CH~
 
 
 
 
 
  	s}55	6       
Ds)D cND #s(^	D
 $(S>D 
D D D D= = = = = = = = =r   r   )typingr   r   r   r   r   r1   ray.dagr   ray.dag.format_utilsr
   ray.util.annotationsr   r    r   r   <module>r9      s    0 0 0 0 0 0 0 0 0 0 0 0 0 0 



       1 1 1 1 1 1 - - - - - - #= #= #= #= #=g #= #= #= #= #=r   