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

Updated ffmpeg stuff

Browse Source
This commit is contained in:
bskjon 2024-07-02 21:44:45 +02:00
parent 1abbd6ecd8
commit c39354da09
4 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -63,7 +63,7 @@ class CreateEncodeWorkTask(@Autowired override var coordinator: EventCoordinator
outFile = e.outFile,
arguments = e.arguments
).let { task ->
val status = taskManager.createTask(referenceId = event.referenceId, 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) {
log.error { "Failed to create Encode task on ${forwardEvent.referenceId}@${forwardEvent.eventId}" }
}

2
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CreateExtractWorkTask.kt
View File

@ -60,7 +60,7 @@ class CreateExtractWorkTask(@Autowired override var coordinator: EventCoordinato
outFile = e.outFile,
arguments = e.arguments
).let { task ->
val status = taskManager.createTask(referenceId = event.referenceId, 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) {
log.error { "Failed to create Extract task on ${forwardEvent.referenceId}@${forwardEvent.eventId}" }
}

3
shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/persistance/TasksManager.kt
View File

@ -123,13 +123,14 @@ class TasksManager(private val dataSource: DataSource) {
}
}
fun createTask(referenceId: String, eventId: String = UUID.randomUUID().toString(), task: TaskType, data: String): Boolean {
fun createTask(referenceId: String, eventId: String = UUID.randomUUID().toString(), derivedFromEventId: String? = null, task: TaskType, data: String): Boolean {
return executeWithStatus(dataSource) {
tasks.insert {
it[tasks.referenceId] = referenceId
it[tasks.eventId] = eventId
it[tasks.task] = task.name
it[tasks.data] = data
it[tasks.derivedFromEventId] = derivedFromEventId
it[tasks.integrity] = getIntegrityOfData(data)
}
}

1
shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/persistance/tasks.kt
View File

@ -14,6 +14,7 @@ object tasks: IntIdTable() {
val consumed: Column<Boolean> = bool("consumed").default(false)
val task: Column<String> = varchar("task",50)
val eventId: Column<String> = varchar("eventId", 50)
val derivedFromEventId: Column<String?> = varchar("derivedFromEventId", 50).nullable()
val data: Column<String> = text("data")
val created: Column<LocalDateTime> = datetime("created").defaultExpression(CurrentDateTime)
val lastCheckIn: Column<LocalDateTime?> = datetime("lastCheckIn").nullable()