ray.dag.input_node.InputNode.execute

InputNode.execute(*args, _ray_cache_refs: bool = False, **kwargs) → ray._raylet.ObjectRef | ActorHandle

Execute this DAG using the Ray default executor _execute_impl().

Parameters:

_ray_cache_refs – If true, stores the the default executor’s return values on each node in this DAG in a cache. These should be a mix of: - ray.ObjectRefs pointing to the outputs of method and function nodes - Serve handles for class nodes - resolved values representing user input at runtime