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 04:33:33 +02:00
parent 645c7b7a8e
commit 7c25437a10
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/ffmpeg/CreateProcesserWorkTask.kt
View File

@ -18,6 +18,7 @@ abstract class CreateProcesserWorkTask(override var coordinator: Coordinator) :
override fun onProcessEvents(event: PersistentMessage, events: List<PersistentMessage>): MessageDataWrapper? { override fun onProcessEvents(event: PersistentMessage, events: List<PersistentMessage>): MessageDataWrapper? {
val started = events.findLast { it.event == KafkaEvents.EventMediaProcessStarted }?.data as MediaProcessStarted? val started = events.findLast { it.event == KafkaEvents.EventMediaProcessStarted }?.data as MediaProcessStarted?
if (started == null) { if (started == null) {
log.info { "${event.referenceId} couldn't find start event" }
return null return null
} }
@ -34,6 +35,7 @@ abstract class CreateProcesserWorkTask(override var coordinator: Coordinator) :
val earg = if (event.data is FfmpegWorkerArgumentsCreated) event.data as FfmpegWorkerArgumentsCreated? else return null val earg = if (event.data is FfmpegWorkerArgumentsCreated) event.data as FfmpegWorkerArgumentsCreated? else return null
if (earg == null || earg.entries.isEmpty()) { if (earg == null || earg.entries.isEmpty()) {
log.info { "${event.referenceId} ffargument is empty" }
return null return null
} }
@ -47,6 +49,7 @@ abstract class CreateProcesserWorkTask(override var coordinator: Coordinator) :
) )
} }
requestEvents.forEach { requestEvents.forEach {
log.info { "${event.referenceId} creating work request based on ${it.derivedFromEventId}" }
super.onResult(it) super.onResult(it)
} }
return null return null