dplutils.pipeline.ray.RayStreamGraphExecutor
============================================

.. currentmodule:: dplutils.pipeline.ray

.. autoclass:: RayStreamGraphExecutor

   
   .. automethod:: __init__

   
   .. rubric:: Methods

   .. autosummary::
   
      ~RayStreamGraphExecutor.__init__
      ~RayStreamGraphExecutor.enqueue_tasks
      ~RayStreamGraphExecutor.execute
      ~RayStreamGraphExecutor.execute_until_output
      ~RayStreamGraphExecutor.from_graph
      ~RayStreamGraphExecutor.get_pending
      ~RayStreamGraphExecutor.is_task_ready
      ~RayStreamGraphExecutor.output_batch_transform
      ~RayStreamGraphExecutor.poll_tasks
      ~RayStreamGraphExecutor.pre_execute
      ~RayStreamGraphExecutor.resolve_completed
      ~RayStreamGraphExecutor.run
      ~RayStreamGraphExecutor.set_config
      ~RayStreamGraphExecutor.set_config_from_dict
      ~RayStreamGraphExecutor.set_context
      ~RayStreamGraphExecutor.source_generator_fun
      ~RayStreamGraphExecutor.split_batch_submit
      ~RayStreamGraphExecutor.task_exhausted
      ~RayStreamGraphExecutor.task_resolve_output
      ~RayStreamGraphExecutor.task_submit
      ~RayStreamGraphExecutor.task_submittable
      ~RayStreamGraphExecutor.validate
      ~RayStreamGraphExecutor.writeto
   
   

   
   
   .. rubric:: Attributes

   .. autosummary::
   
      ~RayStreamGraphExecutor.run_id
      ~RayStreamGraphExecutor.tasks_idx