diff --git a/backend/src/worker_flow.rs b/backend/src/worker_flow.rs
index ea4ab314e7..c6cf116f73 100644
--- a/backend/src/worker_flow.rs
+++ b/backend/src/worker_flow.rs
@@ -277,11 +277,10 @@ pub async fn update_flow_status_in_progress(
     let step = get_step_of_flow_status(db, flow).await?;
     sqlx::query(&format!(
         "UPDATE queue
-            SET flow_status = jsonb_set(flow_status, '{{modules, {}, job}}', $1)
+            SET flow_status = jsonb_set(flow_status, '{{modules, {step}, job}}', $1)
             WHERE id = $2 AND workspace_id = $3",
-        step
     ))
-    .bind(job_in_progress)
+    .bind(job_in_progress.to_string())
     .bind(flow)
     .bind(w_id)
     .execute(db)