diff --git a/backend/windmill-queue/src/jobs.rs b/backend/windmill-queue/src/jobs.rs
index fb35ea1c34..8864695d81 100644
--- a/backend/windmill-queue/src/jobs.rs
+++ b/backend/windmill-queue/src/jobs.rs
@@ -3618,8 +3618,8 @@ pub async fn push<'c, R: rsmq_async::RsmqConnection + Send + 'c>(
         Json(args) as Json<PushArgs>,
         job_kind.clone() as JobKind,
         schedule_path,
-        Json(raw_flow) as Json<Option<FlowValue>>,
-        Json(flow_status) as Json<Option<FlowStatus>>,
+        raw_flow.map(Json) as Option<Json<FlowValue>>,
+        flow_status.map(Json) as Option<Json<FlowStatus>>,
         is_flow_step,
         language as Option<ScriptLang>,
         same_worker,