diff --git a/backend/windmill-api/src/jobs.rs b/backend/windmill-api/src/jobs.rs index 625a353f00..f3ba9e5ae9 100644 --- a/backend/windmill-api/src/jobs.rs +++ b/backend/windmill-api/src/jobs.rs @@ -5861,6 +5861,17 @@ fn get_job_update_sse_stream( // Check if job is completed if update.completed.unwrap_or(false) { + // let full_job = get_job_by_id(db, &job_id).await?; + + let mut get = GetQuery::new() + .with_auth(&opt_authed) + .without_logs(); + + let full_job = get.fetch(&db, job_id, &w_id).await?; + + tx.send( + format!("data: {{'completed': true, 'job': {}}}\n\n", + serde_json::to_string(&full_job).unwrap())).await.unwrap(); break; } }