From 9ebcaacc38b9e32a2c11c3939e255dcc72ee1d2c Mon Sep 17 00:00:00 2001 From: bskjon Date: Mon, 1 Jul 2024 00:55:30 +0200 Subject: [PATCH] Removed old checking --- .../tasks/event/CompleteMediaTask.kt | 23 ------------------- 1 file changed, 23 deletions(-) diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteMediaTask.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteMediaTask.kt index 68715a51..969b6321 100644 --- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteMediaTask.kt +++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteMediaTask.kt @@ -64,29 +64,6 @@ class CompleteMediaTask(@Autowired override var coordinator: EventCoordinator) : } - val hasEncodeAndIsRequired = if (startedData.operations.contains(StartOperationEvents.ENCODE)) { - events.any { it.event == EventWorkEncodePerformed } - } else true - - val hasExtractAndIsRequired = if (startedData.operations.contains(StartOperationEvents.EXTRACT)) { - events.any { it.event == EventWorkExtractPerformed} - } else true - - val hasConvertAndIsRequired = if (startedData.operations.contains(StartOperationEvents.CONVERT)) { - events.any { it.event == EventWorkConvertPerformed } - } else true - - val missingRequired: MutableMap = mutableMapOf( - StartOperationEvents.ENCODE to hasEncodeAndIsRequired, - StartOperationEvents.EXTRACT to hasExtractAndIsRequired, - StartOperationEvents.CONVERT to hasConvertAndIsRequired - ) - - if (missingRequired.values.any { !it }) { - log.info { "Waiting for ${missingRequired.entries.filter { !it.value }.map { it.key.name }}" } - return null - } - val ch = CompleteHandler(events) val chEvents = ch.getMissingCompletions() if (chEvents.isNotEmpty()) {