This commit is contained in:
bskjon 2024-04-22 23:59:56 +02:00
parent e5bb1c1733
commit 1e394c1938

View File

@ -11,6 +11,7 @@ import no.iktdev.mediaprocessing.processer.eventManager
import no.iktdev.mediaprocessing.shared.kafka.dto.events_result.FfmpegWorkRequestCreated import no.iktdev.mediaprocessing.shared.kafka.dto.events_result.FfmpegWorkRequestCreated
import java.io.File import java.io.File
import java.time.Duration import java.time.Duration
import java.util.UUID
class FfmpegWorker( class FfmpegWorker(
val referenceId: String, val referenceId: String,
@ -65,7 +66,7 @@ class FfmpegWorker(
} }
fun runWithProgress() { fun runWithProgress() {
log.info { "Starting ffmpeg ReferenceId: $referenceId, eventId $eventId for file ${info.outFile}" } log.info { "Starting ffmpeg ReferenceId: $referenceId, eventId $eventId for file ${info.outFile}, debugId: ${UUID.randomUUID().toString()}" }
val args = FfmpegWorkerArgumentsBuilder().using(info).buildWithProgress() val args = FfmpegWorkerArgumentsBuilder().using(info).buildWithProgress()
job = scope.launch { job = scope.launch {
execute(args) execute(args)