File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11use crate :: traits:: IdentifiableFlow ;
22use async_nats:: jetstream:: kv:: Config ;
3- use code0_flow:: flow_validator:: verify_flow;
43use futures_lite:: StreamExt ;
54use prost:: Message ;
65use tucana:: shared:: { ExecutionFlow , ValidationFlow , Value } ;
@@ -119,17 +118,7 @@ impl AdapterStore {
119118 flow : ValidationFlow ,
120119 input_value : Option < Value > ,
121120 ) -> Option < Value > {
122- if let Some ( body) = input_value. clone ( ) {
123- let verify_result = verify_flow ( flow. clone ( ) , body) ;
124-
125- match verify_result {
126- Ok ( ( ) ) => { }
127- Err ( _err) => {
128- return None ;
129- }
130- } ;
131- }
132-
121+ // TODO: Replace body vaidation with triangulus when its ready
133122 let uuid = uuid:: Uuid :: new_v4 ( ) . to_string ( ) ;
134123 let flow_id = flow. flow_id ;
135124 let execution_flow: ExecutionFlow = Self :: convert_validation_flow ( flow, input_value) ;
You can’t perform that action at this time.
0 commit comments