Skip to content

pipeline

trestle.core.pipeline ¤

Abstract base class for pipelines and filters.

Classes¤

Pipeline ¤

Pipeline base class.

Source code in trestle/core/pipeline.py 
class Pipeline():
    """Pipeline base class."""

    class Filter(ABC):
        """Filter class used by pipeline."""

        @abstractclassmethod
        def process(self, input_: Any) -> Any:
            """Process the input to output."""
            return input_

    def __init__(self, filters: List[Filter]) -> None:
        """Initialize the class."""
        self._filters = filters

    def process(self, input_: Any) -> Any:
        """Process the filter pipeline."""
        for filter_ in self._filters:
            input_ = filter_.process(input_)
        return input_
Classes¤
Filter (ABC) ¤

Filter class used by pipeline.

Source code in trestle/core/pipeline.py 
class Filter(ABC):
    """Filter class used by pipeline."""

    @abstractclassmethod
    def process(self, input_: Any) -> Any:
        """Process the input to output."""
        return input_
Methods¤
process(input_) classmethod ¤

Process the input to output.

Source code in trestle/core/pipeline.py 
@abstractclassmethod
def process(self, input_: Any) -> Any:
    """Process the input to output."""
    return input_
Methods¤
__init__(self, filters) special ¤

Initialize the class.

Source code in trestle/core/pipeline.py 
def __init__(self, filters: List[Filter]) -> None:
    """Initialize the class."""
    self._filters = filters
process(self, input_) ¤

Process the filter pipeline.

Source code in trestle/core/pipeline.py 
def process(self, input_: Any) -> Any:
    """Process the filter pipeline."""
    for filter_ in self._filters:
        input_ = filter_.process(input_)
    return input_

handler: python