morpheus.pipeline#

All objects related to building and running a pipeline.

Modules

`boundary_stage_mixin`
`configurable_output_source`	Base class for single output source stages which support both `MessageMeta` and `ControlMessage` as output types.
`control_message_stage`
`execution_mode_mixins`	Mixins to indicate which execution modes are supported for a given stage.
`linear_pipeline`
`pass_thru_type_mixin`	Mixin for single port stages which receive and emit the same type.
`pipeline`
`preallocator_mixin`	Mixin used by stages which are emitting newly constructed DataFrame or MessageMeta instances into the segment.
`receiver`
`sender`
`single_output_source`
`single_port_stage`
`source_stage`
`stage`
`stage_base`
`stage_decorator`
`stage_schema`