Install above transformer into the existing pipeline creator.

def install_new_pipeline():
    """
    Install above transformer into the existing pipeline creator.
    """

    def new_create_pipeline(context, *args, **kwargs):
        result = old_create_pipeline(context, *args, **kwargs)
        result.insert(1, DAAPObjectTransformer(context))

        return result

    old_create_pipeline = Pipeline.create_pipeline
    Pipeline.create_pipeline = new_create_pipeline