diff --git a/backend/src/worker_flow.rs b/backend/src/worker_flow.rs index fa8f547ec6..531651b928 100644 --- a/backend/src/worker_flow.rs +++ b/backend/src/worker_flow.rs @@ -1048,6 +1048,14 @@ async fn push_next_flow_job( ) .await? } + FlowModuleValue::Identity => match last_result.clone() { + Value::Object(m) => m, + v @ _ => { + let mut m = Map::new(); + m.insert("previous_result".to_string(), v); + m + } + }, _ => { /* embedded flow input is augmented with embedding flow input */ if let Some(value) = &flow_job.args { diff --git a/frontend/src/lib/components/ArgInput.svelte b/frontend/src/lib/components/ArgInput.svelte index f159ad8526..d28f9e1176 100644 --- a/frontend/src/lib/components/ArgInput.svelte +++ b/frontend/src/lib/components/ArgInput.svelte @@ -1,6 +1,4 @@ +
Synchronized with main signature
-- Argument names, being required or not, and default values are derived from the main - signature of step 2 and cannot be edited directly. Change the main signature to edit - them. -
-