def METHOD_NAME(self, pipelines):
    client = local_session(
        self.manager.session_factory).client('datapipeline')
    for p in pipelines:
        try:
            client.delete_pipeline(pipelineId=p['id'])
        except client.exceptions.PipelineNotFoundException:
            continue