class PipelineAlreadyExistsException(Exception):
def __init__(self, pipe_name):
super(f"Pipeline {pipe_name} already exists")