Merge pull request #53 from kdesjard/fix_dag_job_test_update_example

examples/yaml_dag.rs

@@ -3,6 +3,7 @@
 extern crate dagrs;
 
 use dagrs::Dag;
+use dagrs::task::Content;
 use dagrs::utils::file::load_file;
 use std::collections::HashMap;
 
@@ -14,5 +15,8 @@ fn main() {
     let content = load_file("tests/config/correct.yaml").unwrap();
     let mut job = Dag::with_yaml_str(&content, HashMap::new()).unwrap();
     assert!(job.start().unwrap());
-
+    let out = job.get_results::<Content>();
+    for (k,v) in out {
+        println!("{k} {:#?}",v.unwrap().get::<(Vec<String>,Vec<String>)>());
+    }
 }

tests/dag_job_test.rs

@@ -3,6 +3,7 @@
 use std::{collections::HashMap, sync::Arc};
 
 use dagrs::{Complex, Dag, DagError, DefaultTask, EnvVar, Input, Output};
+use dagrs::task::Content;
 
 #[test]
 fn yaml_task_correct_execute() {
@@ -72,7 +73,7 @@ struct FailedActionD(usize);
 
 impl Complex for FailedActionD {
     fn run(&self, _input: Input, _env: Arc<EnvVar>) -> Output {
-        Output::Err("error".to_string())
+        Output::Err(None,Some(Content::new("error".to_string())))
     }
 }