Skip to content

Commit cd4bb19

Browse files
committed
fix: injected flow input to context
1 parent 8d0e88d commit cd4bb19

1 file changed

Lines changed: 7 additions & 1 deletion

File tree

crates/taurus/src/main.rs

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,13 @@ fn handle_message(
3232
nats_remote: &RemoteNatsClient,
3333
) -> (Signal, RuntimeUsage) {
3434
let start = Instant::now();
35-
let mut context = Context::default();
35+
let mut context = match flow.input_value {
36+
Some(v) => {
37+
log::debug!("Input Value for flow: {:?}", v);
38+
Context::new(v)
39+
},
40+
None => Context::default(),
41+
};
3642

3743
let node_functions: HashMap<i64, NodeFunction> = flow
3844
.node_functions

0 commit comments

Comments
 (0)