diff --git a/backend/src/worker_flow.rs b/backend/src/worker_flow.rs index 48fec1b331..4f0d3df334 100644 --- a/backend/src/worker_flow.rs +++ b/backend/src/worker_flow.rs @@ -157,6 +157,7 @@ pub async fn update_flow_status_after_job_completion( WHERE id = ANY($1) AND workspace_id = $2 AND success = true + ORDER BY args->>'_index' ", ) .bind(jobs.as_slice())