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

Updated check

Browse Source
This commit is contained in:
bskjon 2024-07-01 22:30:00 +02:00
parent 2b3c3f7f52
commit 7cd4591bf1
1 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/utils/TasksUtil.kt
View File

@ -50,7 +50,7 @@ fun isAwaitingPrecondition(tasks: List<TaskType>, events: List<PersistentMessage
fun isAwaitingTask(task: TaskType, events: List<PersistentMessage>): Boolean { fun isAwaitingTask(task: TaskType, events: List<PersistentMessage>): Boolean {
return when (task) { val taskStatus = when (task) {
TaskType.Encode -> { TaskType.Encode -> {
val argumentEvent = KafkaEvents.EventMediaParameterEncodeCreated val argumentEvent = KafkaEvents.EventMediaParameterEncodeCreated
val taskCreatedEvent = KafkaEvents.EventWorkEncodeCreated val taskCreatedEvent = KafkaEvents.EventWorkEncodeCreated
@ -67,9 +67,8 @@ fun isAwaitingTask(task: TaskType, events: List<PersistentMessage>): Boolean {
) )
} }
trailingEvents.filter { it.isOfEvent(taskCreatedEvent) }.size != trailingEvents.filter { it.isOfEvent(taskCreatedEvent) }.size val waiting = trailingEvents.filter { it.isOfEvent(taskCreatedEvent) }.size != trailingEvents.filter { it.isOfEvent(taskCreatedEvent) }.size
waiting
} }
TaskType.Extract -> { TaskType.Extract -> {
val argumentEvent = KafkaEvents.EventMediaParameterExtractCreated val argumentEvent = KafkaEvents.EventMediaParameterExtractCreated
@ -85,7 +84,8 @@ fun isAwaitingTask(task: TaskType, events: List<PersistentMessage>): Boolean {
taskCompletedEvent taskCompletedEvent
) )
} }
trailingEvents.filter { it.isOfEvent(taskCreatedEvent) }.size != trailingEvents.filter { it.isOfEvent(taskCreatedEvent) }.size val waiting = trailingEvents.filter { it.isOfEvent(taskCreatedEvent) }.size != trailingEvents.filter { it.isOfEvent(taskCreatedEvent) }.size
waiting
} }
TaskType.Convert -> { TaskType.Convert -> {
@ -105,8 +105,13 @@ fun isAwaitingTask(task: TaskType, events: List<PersistentMessage>): Boolean {
taskCompletedEvent taskCompletedEvent
) )
} }
trailingEvents.filter { it.isOfEvent(taskCreatedEvent) }.size != trailingEvents.filter { it.isOfEvent(taskCreatedEvent) }.size val waiting = trailingEvents.filter { it.isOfEvent(taskCreatedEvent) }.size != trailingEvents.filter { it.isOfEvent(taskCreatedEvent) }.size
waiting
} }
} }
} }
if (taskStatus) {
log.info { "isAwaiting for $task" }
}
return taskStatus
} }