o 1 iy@sXddlmZmZmZddlZddlmZddlmZddl m Z e GdddeZ dS))AnyDictListN)DAGNode)get_dag_node_str) DeveloperAPIc speZdZdZ dfdd Zdeedeeefdeeefdeeeffd d Z d d Z d efddZ Z S) FunctionNodez/Represents a bound task node in a Ray task DAG.Ncs||_tj||||ddSN)other_args_to_resolve)_bodysuper__init__)selfZ func_bodyZ func_argsZ func_kwargsZ func_optionsr  __class__a/home/app/PaddleOCR-VL-test/.venv_paddleocr/lib/python3.10/site-packages/ray/dag/function_node.pyr s zFunctionNode.__init__new_args new_kwargs new_optionsnew_other_args_to_resolvecCst|j||||dSr )rr )rrrrrrrr _copy_implszFunctionNode._copy_implcOs*t|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. Nr)rayremoter optionsZ_bound_optionsZ _bound_argsZ _bound_kwargs)rargskwargsrrr _execute_impl,s zFunctionNode._execute_implreturncCst|t|jSN)rstrr )rrrr__str__:szFunctionNode.__str__r) __name__ __module__ __qualname____doc__r rrrr rrr! __classcell__rrrrr s    r) typingrrrrZray.dag.dag_noderZray.dag.format_utilsrZray.util.annotationsrrrrrrs