starred/windmill
1
0
Fork 0
mirror of https://github.com/windmill-labs/windmill.git synced 2026-08-25 08:00:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

improve debug info endpoint

Browse Source
This commit is contained in:
Ruben Fiszel
2024-02-05 12:41:41 +01:00
parent 273973a86a
commit f5afd6e25d
1 changed files with 11 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/windmill-api/src/jobs.rs
+11 -4
View File
@@ -450,7 +450,7 @@ async fn get_flow_job_debug_info(
));
}
let mut jobs = HashMap::new();
jobs.insert("root_job".to_string(), job.clone());
jobs.insert("root_job".to_string(), Job::QueuedJob(job.clone()));
let mut job_ids = vec![];
let jobs_with_root = sqlx::query_scalar!(
@@ -476,9 +476,9 @@ async fn get_flow_job_debug_info(
}
}
for job_id in job_ids {
let job = get_queued_job(job_id, w_id.as_str(), &db).await?;
if let Some(job) = job {
jobs.insert(job.id.to_string(), job);
let job = get_job_internal(&db, w_id.as_str(), job_id).await;
if let Ok(job) = job {
jobs.insert(job.id().to_string(), job);
}
}
Ok(Json(jobs).into_response())
@@ -1562,6 +1562,13 @@ impl Job {
Job::CompletedJob(job) => &job.job_kind,
}
}
pub fn id(&self) -> Uuid {
match self {
Job::QueuedJob(job) => job.id,
Job::CompletedJob(job) => job.id,
}
}
}
#[derive(sqlx::FromRow)]