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

Added missing code

Browse Source
This commit is contained in:
bskjon 2024-07-24 01:34:49 +02:00
parent 4e54445170
commit 778a2045a0
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/tasks/ConvertService.kt
View File

@ -8,6 +8,7 @@ import no.iktdev.eventi.data.EventStatus
import no.iktdev.mediaprocessing.converter.* import no.iktdev.mediaprocessing.converter.*
import no.iktdev.mediaprocessing.converter.convert.ConvertListener import no.iktdev.mediaprocessing.converter.convert.ConvertListener
import no.iktdev.mediaprocessing.converter.convert.Converter2 import no.iktdev.mediaprocessing.converter.convert.Converter2
import no.iktdev.mediaprocessing.shared.common.persistance.Status
import no.iktdev.mediaprocessing.shared.common.services.TaskService import no.iktdev.mediaprocessing.shared.common.services.TaskService
import no.iktdev.mediaprocessing.shared.common.task.Task import no.iktdev.mediaprocessing.shared.common.task.Task
import no.iktdev.mediaprocessing.shared.contract.data.ConvertData import no.iktdev.mediaprocessing.shared.contract.data.ConvertData
@ -104,7 +105,9 @@ class ConvertService(
override fun onError(inputFile: String, message: String) { override fun onError(inputFile: String, message: String) {
val task = assignedTask ?: return val task = assignedTask ?: return
super.onError(inputFile, message) super.onError(inputFile, message)
log.info { "Convert error for ${task.referenceId}" } log.info { "Convert error for ${task.referenceId}\nmessage: $message" }
taskManager.markTaskAsCompleted(task.referenceId, task.eventId, Status.ERROR)
tasks.onProduceEvent(ConvertWorkPerformed( tasks.onProduceEvent(ConvertWorkPerformed(
metadata = EventMetadata( metadata = EventMetadata(
@ -114,6 +117,7 @@ class ConvertService(
source = getProducerName() source = getProducerName()
) )
)) ))
onClearTask()
} }