From 9e3a938ce4928ec1af6fa62a2cbacfba71539e6b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Brage=20Skj=C3=B8nborg?= <bskjon@outlook.com>
Date: Thu, 29 Jan 2026 23:15:08 +0100
Subject: [PATCH] Fixed wrong query

---
 .../mediaprocessing/coordinator/controller/TaskController.kt  | 4 ++--
 .../mediaprocessing/shared/common/dto/ResetTaskResponse.kt    | 2 +-
 .../mediaprocessing/shared/database/stores/TaskStore.kt       | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/controller/TaskController.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/controller/TaskController.kt
index 95088310..475b48de 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/controller/TaskController.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/controller/TaskController.kt
@@ -56,13 +56,13 @@ class TaskController(
         }
 
         // 2. Reset task
-        taskService.resetFailedTask(taskId)
+        val success = taskService.resetFailedTask(taskId)
 
         return ResponseEntity.ok(
             ResetTaskResponse(
                 taskId = taskId,
                 referenceId = referenceId,
-                status = "reset",
+                reset = success,
                 deletedEventId = deletedId,
                 resetAt = UtcNow()
             )
diff --git a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/dto/ResetTaskResponse.kt b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/dto/ResetTaskResponse.kt
index 47eb14ba..5c708b8a 100644
--- a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/dto/ResetTaskResponse.kt
+++ b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/dto/ResetTaskResponse.kt
@@ -7,6 +7,6 @@ data class ResetTaskResponse(
     val taskId: UUID,
     val referenceId: UUID,
     val deletedEventId: UUID?,
-    val status: String,
+    val reset: Boolean,
     val resetAt: Instant
 )
diff --git a/shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/stores/TaskStore.kt b/shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/stores/TaskStore.kt
index 380b680d..67c84fb5 100644
--- a/shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/stores/TaskStore.kt
+++ b/shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/stores/TaskStore.kt
@@ -185,7 +185,7 @@ object TaskStore: TaskStore {
         return withTransaction {
             TasksTable.update({
                 (TasksTable.claimed eq true) and
-                        (TasksTable.consumed eq false) and
+                        (TasksTable.consumed eq true) and
                         (TasksTable.status eq TaskStatus.Failed) and
                         (TasksTable.taskId eq taskId.toString())
             }) {