class_docstr: Experimental class for accelerated execution.
  
  This class should not be called directly. Instead, create
  a ray.dag and call experimental_compile().
  
  See REP https://github.com/ray-project/enhancements/pull/48 for more
  information.
class_docstr_tok: ["Experimental","class","for","accelerated","execution",".","This","class","should","not","be","called","directly",".","Instead",",","create","a","ray.dag","and","call","experimental_compile","(",")",".","See","REP","https",":","\/\/github.com\/ray-project\/enhancements\/pull\/48","for","more","information","."]
docstr: Execute this DAG using the compiled execution path.
  
  Args:
      args: Args to the InputNode.
      kwargs: Kwargs to the InputNode. Not supported yet.
  
  Returns:
      A list of Channels that can be used to read the DAG result.
docstr_tok: ["Execute","this","DAG","using","the","compiled","execution","path",".","Args",":","args",":","Args","to","the","InputNode",".","kwargs",":","Kwargs","to","the","InputNode",".","Not","supported","yet",".","Returns",":","A","list","of","Channels","that","can","be","used","to","read","the","DAG","result","."]
code: def execute(
      self,
      *args,
      **kwargs,
  ) -> Union[Channel, List[Channel]]:
      """Execute this DAG using the compiled execution path.
  
      Args:
          args: Args to the InputNode.
          kwargs: Kwargs to the InputNode. Not supported yet.
  
      Returns:
          A list of Channels that can be used to read the DAG result.
      """
      # These errors should already be caught during compilation, but just in
      # case.
      if len(args) != 1:
          raise NotImplementedError(
              "Compiled DAGs support exactly one InputNode arg"
          )
      if len(kwargs) != 0:
          raise NotImplementedError(
              "Compiled DAGs do not support kwargs"
          )
  
      input_channel, output_channels = self._get_or_compile()
      input_channel.write(args[0])
      return output_channels
  
imports: from collections import defaultdict
  from typing import Any, Dict, List, Tuple, Union, Optional
  import logging
  import threading
  import traceback
  import ray
  from ray.exceptions import RayTaskError
  from ray.experimental.channel import Channel
  from ray.util.annotations import DeveloperAPI
label_desc: Use image node_id 6 for calling the CompiledDAG obj's underlying member method code with example usage: obj.execute() and returns: output_channels