trestle.core.pipeline

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_