&`iyrddlmZmZmZddlZddlmZddlmZddl m Z e GddeZ dS))AnyDictListN)DAGNode)get_dag_node_str) DeveloperAPIc eZdZdZ d fd ZdeedeeefdeeefdeeeffdZ d Z d efd Z xZ S) FunctionNodez/Represents a bound task node in a Ray task DAG.Nc`||_t||||dSN)other_args_to_resolve)_bodysuper__init__)self func_body func_args func_kwargs func_optionsr __class__s i/home/jaya/work/projects/VOICE-AGENT/VIET/agent-env/lib/python3.11/site-packages/ray/dag/function_node.pyrzFunctionNode.__init__ sC     "7      new_args new_kwargs new_optionsnew_other_args_to_resolvec4t|j||||Sr )r r)rrrrrs r _copy_implzFunctionNode._copy_impls, J   ";     rc~tj|jjdi|jj|ji|jS)a:Executor of FunctionNode by ray.remote(). Args and kwargs are to match base class signature, but not in the implementation. All args and kwargs should be resolved and replaced with value in bound_args and bound_kwargs via bottom-up recursion when current node is executed. )rayremoteroptions_bound_options _bound_args _bound_kwargs)rargskwargss r _execute_implzFunctionNode._execute_impl,sY  CJtz " "  , ,* , , T% =)-); = = rreturncFt|t|jSN)rstrr)rs r__str__zFunctionNode.__str__:sc$*oo666rr,) __name__ __module__ __qualname____doc__rrrrr-rr)r. __classcell__)rs@rr r s99#        s)  cN  #s(^  $(S>         777777777rr ) typingrrrr!ray.dag.dag_noderray.dag.format_utilsrray.util.annotationsrr r rrr8s"""""""""" $$$$$$111111------171717171771717171717r