From b0f6e354ea7c18e1abe8aa2f9e420f6c61fba430 Mon Sep 17 00:00:00 2001
From: bskjon <bskjon@outlook.com>
Date: Mon, 6 May 2024 00:53:26 +0200
Subject: [PATCH] Changed to listens for

---
 .../coordinator/tasks/event/CreateConvertWorkTask.kt        | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateConvertWorkTask.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateConvertWorkTask.kt
index f2602ddc..a1e1f15c 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateConvertWorkTask.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateConvertWorkTask.kt
@@ -24,12 +24,8 @@ class CreateConvertWorkTask(@Autowired override var coordinator: Coordinator) :
     override val producesEvent: KafkaEvents
         get() = KafkaEvents.EventWorkConvertCreated
 
-    override val requiredEvents: List<KafkaEvents>
-        get() = listOf(
-            KafkaEvents.EventWorkExtractCreated
-        )
     override val listensForEvents: List<KafkaEvents>
-        get() = listOf(KafkaEvents.EventMediaProcessStarted)
+        get() = listOf(KafkaEvents.EventMediaProcessStarted, KafkaEvents.EventWorkExtractCreated)
 
     override fun onProcessEvents(event: PersistentMessage, events: List<PersistentMessage>): MessageDataWrapper? {
         super.onProcessEventsAccepted(event, events)