From 2b3c3f7f52d5bf2b3e116e78798239ac73912cca Mon Sep 17 00:00:00 2001
From: bskjon <bskjon@outlook.com>
Date: Mon, 1 Jul 2024 21:47:27 +0200
Subject: [PATCH] Updated check

---
 .../iktdev/mediaprocessing/coordinator/utils/TasksUtil.kt | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/utils/TasksUtil.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/utils/TasksUtil.kt
index 0b12efe0..d9fc4d50 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/utils/TasksUtil.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/utils/TasksUtil.kt
@@ -20,15 +20,15 @@ fun isAwaitingPrecondition(tasks: List<TaskType>, events: List<PersistentMessage
         }
     }
 
-    val convertEvent = events.lastOrNull { it.isOfEvent(KafkaEvents.EventWorkConvertCreated) } == null
-    if (tasks.any { it == TaskType.Convert } && tasks.none {it == TaskType.Extract}) {
-        if (convertEvent) {
+    val convertEvent = events.lastOrNull { it.isOfEvent(KafkaEvents.EventWorkConvertCreated) }
+    if (tasks.any { it == TaskType.Convert } && tasks.none { it == TaskType.Extract }) {
+        if (convertEvent == null) {
             response[TaskType.Convert] = true
             log.info { "Waiting for ${KafkaEvents.EventWorkConvertCreated}" }
         }
     } else if (tasks.any { it == TaskType.Convert }) {
         val extractEvent =  events.lastOrNull { it.isOfEvent(KafkaEvents.EventMediaParameterExtractCreated) }
-        if (extractEvent == null || extractEvent.isSuccess() && !convertEvent) {
+        if (extractEvent == null || extractEvent.isSuccess() && convertEvent == null) {
             response[TaskType.Convert] = true
             log.info { "Waiting for ${KafkaEvents.EventMediaParameterExtractCreated}" }
         }