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

fix: fix label from completed_job

Browse Source
This commit is contained in:
Ruben Fiszel
2024-04-24 09:50:34 +02:00
parent eb698db45e
commit ed6fcc761c
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/tests/worker.rs
+1 -1
View File
@@ -1026,7 +1026,7 @@ async fn listen_for_uuid_on(
async fn completed_job(uuid: Uuid, db: &Pool<Postgres>) -> CompletedJob {
sqlx::query_as::<_, CompletedJob>("SELECT * FROM completed_job WHERE id = $1").bind(uuid)
sqlx::query_as::<_, CompletedJob>("SELECT *, result->>'wm_label' as label FROM completed_job WHERE id = $1").bind(uuid)
.fetch_one(db)
.await
.unwrap()
backend/windmill-api/src/jobs.rs
+1 -1
View File
@@ -2298,7 +2298,7 @@ pub async fn restart_flow(
check_license_key_valid().await?;
let completed_job = sqlx::query_as::<_, CompletedJob>(
"SELECT * from completed_job WHERE id = $1 and workspace_id = $2",
"SELECT *, result->>'wm_label' as label from completed_job WHERE id = $1 and workspace_id = $2",
)
.bind(job_id)
.bind(&w_id)
backend/windmill-queue/src/jobs.rs
+2 -2
View File
@@ -2076,7 +2076,7 @@ async fn get_result_by_id_from_original_flow(
json_path: Option<String>,
) -> error::Result<Box<RawValue>> {
let flow_job = sqlx::query_as::<_, CompletedJob>(
"SELECT * FROM completed_job WHERE id = $1 AND workspace_id = $2",
"SELECT *, null as label FROM completed_job WHERE id = $1 AND workspace_id = $2",
)
.bind(completed_flow_id)
.bind(w_id)
@@ -3469,7 +3469,7 @@ async fn restarted_flows_resolution(
Error,
> {
let completed_job = sqlx::query_as::<_, CompletedJob>(
"SELECT * FROM completed_job WHERE id = $1 and workspace_id = $2",
"SELECT *, null as label FROM completed_job WHERE id = $1 and workspace_id = $2",
)
.bind(completed_flow_id)
.bind(workspace_id)