Function pipeline

pub fn pipeline(
    graph: Arc<Mutex<Graph>>,
    name: String,
) -> Result<Pipeline, Error>