sdf_parser_df/
lib.rs

1pub mod config;
2
3pub use parser::*;
4
5pub mod parser {
6
7    use crate::config;
8
9    pub fn parse(data_pipeline: &str) -> anyhow::Result<config::DataflowDefinitionConfig> {
10        let yd = serde_yaml::Deserializer::from_str(data_pipeline);
11        let config = serde_path_to_error::deserialize(yd)?;
12
13        Ok(config)
14    }
15}