iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed wrong query

Browse Source
This commit is contained in:
Brage Skjønborg 2026-01-29 23:15:08 +01:00
parent ea75487682
commit 9e3a938ce4
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/controller/TaskController.kt
View File

@ -56,13 +56,13 @@ class TaskController(
} }
// 2. Reset task // 2. Reset task
taskService.resetFailedTask(taskId) val success = taskService.resetFailedTask(taskId)
return ResponseEntity.ok( return ResponseEntity.ok(
ResetTaskResponse( ResetTaskResponse(
taskId = taskId, taskId = taskId,
referenceId = referenceId, referenceId = referenceId,
status = "reset", reset = success,
deletedEventId = deletedId, deletedEventId = deletedId,
resetAt = UtcNow() resetAt = UtcNow()
) )

2
shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/dto/ResetTaskResponse.kt
View File

@ -7,6 +7,6 @@ data class ResetTaskResponse(
val taskId: UUID, val taskId: UUID,
val referenceId: UUID, val referenceId: UUID,
val deletedEventId: UUID?, val deletedEventId: UUID?,
val status: String, val reset: Boolean,
val resetAt: Instant val resetAt: Instant
) )

2
shared/database/src/main/kotlin/no/iktdev/mediaprocessing/shared/database/stores/TaskStore.kt
View File

@ -185,7 +185,7 @@ object TaskStore: TaskStore {
return withTransaction { return withTransaction {
TasksTable.update({ TasksTable.update({
(TasksTable.claimed eq true) and (TasksTable.claimed eq true) and
(TasksTable.consumed eq false) and (TasksTable.consumed eq true) and
(TasksTable.status eq TaskStatus.Failed) and (TasksTable.status eq TaskStatus.Failed) and
(TasksTable.taskId eq taskId.toString()) (TasksTable.taskId eq taskId.toString())
}) { }) {