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

Logging

Browse Source
This commit is contained in:
bskjon 2024-07-04 16:35:09 +02:00
parent e48a529a77
commit 7380e8a23e
2 changed files with 16 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateConvertWorkTask.kt
View File

@ -55,7 +55,11 @@ class CreateConvertWorkTask(@Autowired override var coordinator: EventCoordinato
innerData?.outFile innerData?.outFile
} else null } else null
val convertFile = result?.let { File(it) } ?: return null val convertFile = result?.let { File(it) }
if (convertFile == null) {
log.warn { "${event.referenceId} No file to perform convert on.." }
return null
}
val taskData = ConvertTaskData( val taskData = ConvertTaskData(
allowOverwrite = true, allowOverwrite = true,
@ -65,24 +69,19 @@ class CreateConvertWorkTask(@Autowired override var coordinator: EventCoordinato
outFormats = emptyList() outFormats = emptyList()
) )
taskManager.createTask( val status = taskManager.createTask(
referenceId = event.referenceId, referenceId = event.referenceId,
eventId = event.eventId, eventId = event.eventId,
task = TaskType.Convert, task = TaskType.Convert,
derivedFromEventId = event.eventId,
data = Gson().toJson(taskData) data = Gson().toJson(taskData)
) )
if (!status) {
log.error { "Failed to create Convert task on ${event.referenceId}@${event.eventId}" }
}
return if (event.isOfEvent(KafkaEvents.EventMediaProcessStarted) &&
event.data.az<MediaProcessStarted>()?.operations?.isOnly(StartOperationEvents.CONVERT) == true
) {
produceConvertWorkRequest(convertFile, null, event.eventId)
} else if (event.isOfEvent(KafkaEvents.EventWorkExtractPerformed) && startedEventData?.operations?.contains(
StartOperationEvents.CONVERT
) == true
) {
return produceConvertWorkRequest(convertFile, event.referenceId, event.eventId)
} else null return produceConvertWorkRequest(convertFile, event.referenceId, event.eventId)
} }
private fun produceConvertWorkRequest( private fun produceConvertWorkRequest(

6
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateEncodeWorkTask.kt
View File

@ -63,7 +63,11 @@ class CreateEncodeWorkTask(@Autowired override var coordinator: EventCoordinator
outFile = e.outFile, outFile = e.outFile,
arguments = e.arguments arguments = e.arguments
).let { task -> ).let { task ->
val status = taskManager.createTask(referenceId = event.referenceId, derivedFromEventId = event.eventId, task= TaskType.Encode, data = Gson().toJson(task)) val status = taskManager.createTask(
referenceId = event.referenceId,
derivedFromEventId = event.eventId,
task = TaskType.Encode,
data = Gson().toJson(task))
if (!status) { if (!status) {
log.error { "Failed to create Encode task on ${forwardEvent.referenceId}@${forwardEvent.eventId}" } log.error { "Failed to create Encode task on ${forwardEvent.referenceId}@${forwardEvent.eventId}" }
} }