diff --git a/backend/tests/worker.rs b/backend/tests/worker.rs
index ded754af14..026e6bfd0e 100644
--- a/backend/tests/worker.rs
+++ b/backend/tests/worker.rs
@@ -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 *, result->'wm_labels' as label FROM completed_job  WHERE id = $1").bind(uuid)
+    sqlx::query_as::<_, CompletedJob>("SELECT *, result->'wm_labels' as labels FROM completed_job  WHERE id = $1").bind(uuid)
         .fetch_one(db)
         .await
         .unwrap()
diff --git a/backend/windmill-queue/src/jobs.rs b/backend/windmill-queue/src/jobs.rs
index 6fb0bccd8f..ec6be0ae03 100644
--- a/backend/windmill-queue/src/jobs.rs
+++ b/backend/windmill-queue/src/jobs.rs
@@ -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 *, null as label FROM completed_job WHERE id = $1 AND workspace_id = $2",
+        "SELECT *, null as labels 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 *, null as label FROM completed_job WHERE id = $1 and workspace_id = $2",
+        "SELECT *, null as labels FROM completed_job WHERE id = $1 and workspace_id = $2",
     )
     .bind(completed_flow_id)
     .bind(workspace_id)