class Pipeline:
    def run(self, input) -> str:
        raise NotImplementedError