dplutils.pipeline.stream.StreamingGraphExecutor
===============================================

.. currentmodule:: dplutils.pipeline.stream

.. autoclass:: StreamingGraphExecutor

   
   .. automethod:: __init__

   
   .. rubric:: Methods

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

   
   
   .. rubric:: Attributes

   .. autosummary::
   
      ~StreamingGraphExecutor.run_id
      ~StreamingGraphExecutor.tasks_idx