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

A bit of logging fix

Browse Source
This commit is contained in:
bskjon 2025-04-01 22:33:00 +02:00
parent 77ba64664f
commit 22c23a6f27
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/ConvertWorkTaskListener.kt
View File

@ -40,16 +40,18 @@ class ConvertWorkTaskListener: WorkTaskListener() {
return false return false
} }
if (!isOfEventsIListenFor(incomingEvent))
return false
if (!incomingEvent.isSuccessful() && !shouldIHandleFailedEvents(incomingEvent)) { if (!incomingEvent.isSuccessful() && !shouldIHandleFailedEvents(incomingEvent)) {
return false return false
} }
val producedEvents = events.filter { it.eventType == produceEvent } val producedEvents = events.filter { it.eventType == produceEvent }
val shouldIHandleAndProduce = producedEvents.none { it.derivedFromEventId() == incomingEvent.eventId() } val shouldIHandleAndProduce = producedEvents.none { it.derivedFromEventId() == incomingEvent.eventId() }
if (shouldIHandleAndProduce) {
log.info { "Permitting handling of event: ${incomingEvent.dataAs<ExtractedData>()?.outputFile}" } val extractedEvent = events.findFirstEventOf<ExtractWorkPerformedEvent>()
if (extractedEvent?.isSuccessful() == true && shouldIHandleAndProduce) {
log.info { "Permitting handling of event: ${extractedEvent.data?.outputFile}" }
} }
val startedWithOperations = events.findFirstEventOf<MediaProcessStartEvent>()?.data?.operations ?: return false val startedWithOperations = events.findFirstEventOf<MediaProcessStartEvent>()?.data?.operations ?: return false
if (startedWithOperations.isOnly(OperationEvents.CONVERT)) { if (startedWithOperations.isOnly(OperationEvents.CONVERT)) {
return true return true