Skip to content

mopipe.core.analysis.pipeline

pipeline.py

This module contains the Pipeline class, which is used to run a series of analysis steps (segments) on the data.

Pipeline Objects

class Pipeline(t.MutableSequence[Segment])

Pipeline

A pipeline is a series of segments that are run on the data.

__init__

def __init__(segments: t.Optional[t.MutableSequence[Segment]] = None) -> None

Initialize a Pipeline.

segments

@property
def segments() -> t.MutableSequence[Segment]

The segments in the pipeline.

segment

def segment(index: int) -> Segment

Get a segment from the pipeline.

add_segment

def add_segment(segment: Segment) -> int

Add a segment to the pipeline.

run

def run(**kwargs) -> t.Any

Run the pipeline.