Pipeline
========

Backbone
--------

.. currentmodule:: dplutils.pipeline

.. autosummary::
   :toctree: generated

   PipelineExecutor
   PipelineTask
   PipelineGraph

Executors
---------

.. currentmodule:: dplutils.pipeline.stream
.. autosummary::
   :toctree: generated

   StreamingGraphExecutor

Ray Execution
-------------

.. currentmodule:: dplutils.pipeline.ray
.. autosummary::
   :toctree: generated

   RayDataPipelineExecutor
   RayStreamGraphExecutor