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

Updated check

Browse Source
This commit is contained in:
bskjon 2024-07-01 21:47:27 +02:00
parent 8024583d36
commit 2b3c3f7f52
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/utils/TasksUtil.kt
View File

@ -20,15 +20,15 @@ fun isAwaitingPrecondition(tasks: List<TaskType>, events: List<PersistentMessage
} }
} }
val convertEvent = events.lastOrNull { it.isOfEvent(KafkaEvents.EventWorkConvertCreated) } == null val convertEvent = events.lastOrNull { it.isOfEvent(KafkaEvents.EventWorkConvertCreated) }
if (tasks.any { it == TaskType.Convert } && tasks.none {it == TaskType.Extract}) { if (tasks.any { it == TaskType.Convert } && tasks.none { it == TaskType.Extract }) {
if (convertEvent) { if (convertEvent == null) {
response[TaskType.Convert] = true response[TaskType.Convert] = true
log.info { "Waiting for ${KafkaEvents.EventWorkConvertCreated}" } log.info { "Waiting for ${KafkaEvents.EventWorkConvertCreated}" }
} }
} else if (tasks.any { it == TaskType.Convert }) { } else if (tasks.any { it == TaskType.Convert }) {
val extractEvent = events.lastOrNull { it.isOfEvent(KafkaEvents.EventMediaParameterExtractCreated) } 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 response[TaskType.Convert] = true
log.info { "Waiting for ${KafkaEvents.EventMediaParameterExtractCreated}" } log.info { "Waiting for ${KafkaEvents.EventMediaParameterExtractCreated}" }
} }