class PipelineStateManager {

  Pipeline removePipeline(PipelineID pipelineID) throws IOException {
    Pipeline pipeline = pipelineStateMap.removePipeline(pipelineID);
    LOG.info("Pipeline {} removed from db", pipeline);
    return pipeline;
  }

  public  PipelineStateManager();

}