leaf_engine.adapt.pipeline
==========================

.. py:module:: leaf_engine.adapt.pipeline


Submodules
----------

.. toctree::
   :maxdepth: 1

   /autoapi/leaf_engine/adapt/pipeline/adapt_action_pipeline/index
   /autoapi/leaf_engine/adapt/pipeline/adapt_consolidated_network_action_pipeline/index
   /autoapi/leaf_engine/adapt/pipeline/adapt_data_prep_pipeline/index
   /autoapi/leaf_engine/adapt/pipeline/adapt_explorer_pipeline/index
   /autoapi/leaf_engine/adapt/pipeline/adapt_gather_etl/index
   /autoapi/leaf_engine/adapt/pipeline/adapt_network_pipeline/index
   /autoapi/leaf_engine/adapt/pipeline/adapt_oa_pipeline/index
   /autoapi/leaf_engine/adapt/pipeline/adapt_observation_pipeline/index
   /autoapi/leaf_engine/adapt/pipeline/adapt_postprocessing_pipeline/index
   /autoapi/leaf_engine/adapt/pipeline/adapt_synthetic_rate_pipeline/index


Functions
---------

.. autoapisummary::

   leaf_engine.adapt.pipeline.action_pipeline
   leaf_engine.adapt.pipeline.consolidated_network_action_pipeline
   leaf_engine.adapt.pipeline.data_prep_pipeline
   leaf_engine.adapt.pipeline.explorer_pipeline
   leaf_engine.adapt.pipeline.get_etl_context
   leaf_engine.adapt.pipeline.network_pipeline
   leaf_engine.adapt.pipeline.oa_pipeline
   leaf_engine.adapt.pipeline.observation_pipeline
   leaf_engine.adapt.pipeline.synthetic_rate_pipeline


Package Contents
----------------

.. py:function:: action_pipeline(adapt_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptDataContext, network_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptNetworkContext, oa_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptOAContext, rate_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptSyntheticRateContext) -> leaf_engine.adapt.context.adapt_contexts.AdaptActionContext

.. py:function:: consolidated_network_action_pipeline(adapt_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptDataContext, action_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptActionContext)

.. py:function:: data_prep_pipeline(cxt: Union[leaf_engine.adapt.context.adapt_contexts.AdaptETLContext, None], equipment_class, params=None, lane_level=False, input_csv_path=None) -> leaf_engine.adapt.context.adapt_contexts.AdaptDataContext

.. py:function:: explorer_pipeline(adapt_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptDataContext, etl_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptETLContext, obs_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptObservationContext, action_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptActionContext) -> leaf_engine.adapt.context.adapt_contexts.AdaptExplorerContext

.. py:function:: get_etl_context(**kwargs) -> leaf_engine.adapt.context.AdaptETLContext

.. py:function:: network_pipeline(adapt_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptDataContext) -> leaf_engine.adapt.context.adapt_contexts.AdaptNetworkContext

.. py:function:: oa_pipeline(etl_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptETLContext) -> leaf_engine.adapt.context.adapt_contexts.AdaptOAContext

.. py:function:: observation_pipeline(adapt_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptDataContext, rate_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptSyntheticRateContext, oa_cxt: leaf_engine.adapt.context.adapt_contexts.AdaptOAContext) -> leaf_engine.adapt.context.adapt_contexts.AdaptObservationContext

.. py:function:: synthetic_rate_pipeline(cxt: leaf_engine.adapt.context.adapt_contexts.AdaptDataContext) -> leaf_engine.adapt.context.adapt_contexts.AdaptSyntheticRateContext