Skip to content

Commit a613e11

Browse files
committed
Add a new common field to all TaskDefinitions
Signed-off-by: Charles d'Avernas <[email protected]>
1 parent 40dfeb3 commit a613e11

File tree

2 files changed

+183
-39
lines changed

2 files changed

+183
-39
lines changed

Diff for: core/src/lib.rs

+8-2
Original file line numberDiff line numberDiff line change
@@ -16,14 +16,20 @@ mod unit_tests {
1616
let title = Some("fake-title".to_string());
1717
let summary = Some("fake-summary".to_string());
1818
let document = WorkflowDefinitionMetadata::new(namespace, name, version, title.clone(), summary.clone(), None);
19+
let mut call_task = CallTaskDefinition::new("http", None, Some(true));
20+
call_task.common.then = Some("continue".to_string());
21+
let do_task = DoTaskDefinition::new(Map::from(vec![("set".to_string(), TaskDefinition::Wait(WaitTaskDefinition::new(OneOfDurationOrIso8601Expression::Duration(Duration::from_milliseconds(200)))))]));
1922
let mut workflow = WorkflowDefinition::new(document);
2023
workflow.do_ = Map::new();
21-
workflow.do_.add("callTask".to_string(), TaskDefinition::Call(CallTaskDefinition::new("http", None, Some(true))));
22-
workflow.do_.add("doTask".to_string(), TaskDefinition::Do(DoTaskDefinition::new(Map::from(vec![("set".to_string(), TaskDefinition::Wait(WaitTaskDefinition::new(OneOfDurationOrIso8601Expression::Duration(Duration::default()))))]))));
24+
workflow.do_.add("callTask".to_string(), TaskDefinition::Call(call_task));
25+
workflow.do_.add("doTask".to_string(), TaskDefinition::Do(do_task));
2326
let json_serialization_result = serde_json::to_string_pretty(&workflow);
2427
let yaml_serialization_result = serde_yaml::to_string(&workflow);
2528
assert!(json_serialization_result.is_ok(), "JSON Serialization failed: {:?}", json_serialization_result.err());
2629
assert!(yaml_serialization_result.is_ok(), "YAML Serialization failed: {:?}", yaml_serialization_result.err());
30+
if let Result::Ok(yaml) = yaml_serialization_result{
31+
println!("{}", yaml)
32+
}
2733
assert_eq!(workflow.document.namespace, namespace);
2834
assert_eq!(workflow.document.name, name);
2935
assert_eq!(workflow.document.version, version);

0 commit comments

Comments
 (0)