Function fluentci_common::pipeline::pipeline

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