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())
             }) {