From 29923771fdac0423569dcd962acd56ea8a0cbc58 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Brage=20Skj=C3=B8nborg?= Date: Fri, 23 Jan 2026 03:03:22 +0100 Subject: [PATCH] Fixed Projection --- .../shared/common/projection/TaskProjection.kt | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/projection/TaskProjection.kt b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/projection/TaskProjection.kt index 5e9f4ac3..16c85116 100644 --- a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/projection/TaskProjection.kt +++ b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/projection/TaskProjection.kt @@ -16,12 +16,11 @@ class TaskProjection(val events: List) { val createdEvent = events.getInstancesOf().ifEmpty { return TaskStatus.NotInitiated } val resultEvent = events.getInstancesOf().ifEmpty { return TaskStatus.Pending } - if (resultEvent.size != createdEvent.size) return TaskStatus.Pending - val created = createdIds(createdEvent) val results = resultIds(resultEvent) - if (!created.all { it in results }) return TaskStatus.Pending + val taskIds = results.filter { it in created } + if (!taskIds.containsAll(created) || taskIds.size != created.size) return TaskStatus.Pending if (resultEvent.any { resultStatus(it) == no.iktdev.eventi.models.store.TaskStatus.Failed }) return TaskStatus.Failed return TaskStatus.Completed