I think you want to adapt a

before_pipeline_run

hook here