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

Update

Browse Source
This commit is contained in:
bskjon 2024-04-20 19:28:00 +02:00
parent 2fea47b841
commit a3a94a5f8c
2 changed files with 14 additions and 2 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/tasks/event/CreateEncodeWorkTask.kt
View File

@ -22,7 +22,13 @@ class CreateEncodeWorkTask(@Autowired override var coordinator: Coordinator) : C
log.info { "${event.referenceId} triggered by ${event.event}" }
val forwardEvent = if (event.event != KafkaEvents.EventMediaParameterEncodeCreated) {
events.findLast { it.event == KafkaEvents.EventMediaParameterEncodeCreated } ?: event
val sevent = events.findLast { it.event == KafkaEvents.EventMediaParameterEncodeCreated }
if (sevent != null) {
log.info { "${event.referenceId} ${event.event} is not of ${KafkaEvents.EventMediaParameterEncodeCreated}, swapping to found event" }
} else {
log.info { "${event.referenceId} ${event.event} is not of ${KafkaEvents.EventMediaParameterEncodeCreated}, could not find required event.." }
}
sevent ?: event
} else event

8
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateExtractWorkTask.kt
View File

@ -22,7 +22,13 @@ class CreateExtractWorkTask(@Autowired override var coordinator: Coordinator) :
log.info { "${event.referenceId} triggered by ${event.event}" }
val forwardEvent = if (event.event != KafkaEvents.EventMediaParameterExtractCreated) {
events.findLast { it.event == KafkaEvents.EventMediaParameterExtractCreated } ?: event
val sevent = events.findLast { it.event == KafkaEvents.EventMediaParameterExtractCreated }
if (sevent != null) {
log.info { "${event.referenceId} ${event.event} is not of ${KafkaEvents.EventMediaParameterExtractCreated}, swapping to found event" }
} else {
log.info { "${event.referenceId} ${event.event} is not of ${KafkaEvents.EventMediaParameterExtractCreated}, could not find required event.." }
}
sevent ?: event
} else event
return super.onProcessEvents(forwardEvent, events)