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

Logging

Browse Source
This commit is contained in:
Brage 2024-03-07 00:44:21 +01:00
parent f48e7419e9
commit 0f5ffe3694
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt
View File

@ -1,5 +1,6 @@
package no.iktdev.mediaprocessing.processer
import com.google.gson.Gson
import mu.KotlinLogging
import no.iktdev.mediaprocessing.shared.common.persistance.PersistentProcessDataMessage
import no.iktdev.mediaprocessing.shared.kafka.core.CoordinatorProducer
@ -59,6 +60,7 @@ abstract class TaskCreator: TaskCreatorListener {
if (prerequisitesRequired(events).all { it.invoke() }) {
val result = onProcessEvents(event, events)
if (result != null) {
log.info { "Event handled on ${this::class.simpleName} ${event.eventId} is: \nSOM\n${Gson().toJson(result)}\nEOM" }
onResult(result)
}
} else {

4
apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/services/EncodeService.kt
View File

@ -136,7 +136,7 @@ class EncodeService: TaskCreator() {
readbackIsSuccess = PersistentDataReader().isProcessEventDefinedAsConsumed(runner.referenceId, runner.eventId, serviceId)
}
producer.sendMessage(referenceId = runner.referenceId, event = producesEvent,
ProcesserEncodeWorkPerformed(status = Status.COMPLETED, producedBy = serviceId, derivedFromEventId = runner.eventId, outFile = runner.info.outFile)
data = ProcesserEncodeWorkPerformed(status = Status.COMPLETED, producedBy = serviceId, derivedFromEventId = runner.eventId, outFile = runner.info.outFile)
)
clearWorker()
}
@ -151,7 +151,7 @@ class EncodeService: TaskCreator() {
}
log.info { "Encode failed for ${runner.referenceId}" }
producer.sendMessage(referenceId = runner.referenceId, event = producesEvent,
ProcesserEncodeWorkPerformed(status = Status.ERROR, message = errorMessage, producedBy = serviceId, derivedFromEventId = runner.eventId)
data = ProcesserEncodeWorkPerformed(status = Status.ERROR, message = errorMessage, producedBy = serviceId, derivedFromEventId = runner.eventId)
)
sendProgress(info = info, ended = true)
clearWorker()