From 3f87f4fa43dd64f6cea42471d21a1744ba6d3d59 Mon Sep 17 00:00:00 2001 From: Ruben Fiszel Date: Wed, 16 Jul 2025 12:50:32 +0000 Subject: [PATCH] all --- backend/windmill-api/src/jobs.rs | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/backend/windmill-api/src/jobs.rs b/backend/windmill-api/src/jobs.rs index bac5b7ff21..a090d0b211 100644 --- a/backend/windmill-api/src/jobs.rs +++ b/backend/windmill-api/src/jobs.rs @@ -5865,6 +5865,7 @@ fn get_job_update_sse_stream( get_progress, running, true, + only_result ).await { Ok(update) => { if let Ok(serialized) = serde_json::to_string(&update) { @@ -5910,6 +5911,9 @@ async fn get_job_update_data( get_full_job_on_completion: bool, only_result: Option, ) -> error::Result { + if only_result.unwrap_or(false) { + todo!() + } else { let record = sqlx::query!( "SELECT c.id IS NOT NULL AS completed, @@ -5981,6 +5985,8 @@ async fn get_job_update_data( None }; + + Ok(JobUpdate { running: record.running, completed: record.completed, @@ -5992,7 +5998,9 @@ async fn get_job_update_data( flow_status: record .flow_status .map(|x: sqlx::types::Json>| x.0), + only_result: None, }) + } } pub fn filter_list_completed_query(