diff --git a/backend/windmill-worker/src/worker_lockfiles.rs b/backend/windmill-worker/src/worker_lockfiles.rs index 5b2a0b5e99..5ea5b74d64 100644 --- a/backend/windmill-worker/src/worker_lockfiles.rs +++ b/backend/windmill-worker/src/worker_lockfiles.rs @@ -602,11 +602,19 @@ pub async fn handle_flow_dependency_job( ) .await?; + let value_lite_with_extras = Json( + serde_json::value::to_raw_value(&FlowValueWithExtras { + value: &value_lite, + notes: extras.as_ref().and_then(|e| e.notes.clone()), + groups: extras.as_ref().and_then(|e| e.groups.clone()), + }) + .map_err(to_anyhow)?, + ); sqlx::query!( "INSERT INTO flow_version_lite (id, value) VALUES ($1, $2) ON CONFLICT (id) DO UPDATE SET value = EXCLUDED.value", version, - Json(value_lite) as Json, + &value_lite_with_extras as &Json>, ) .execute(&mut *tx) .await?;