diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteMediaTask.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteMediaTask.kt index 7b46ad42..ab3dfd59 100644 --- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteMediaTask.kt +++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteMediaTask.kt @@ -92,16 +92,15 @@ class CompleteMediaTask(@Autowired override var coordinator: EventCoordinator) : isAwaitingTask(it, events) }.any { it } - - - //val mapper = ProcessMapping(events) //if (mapper.canCollect()) { - if (isWaiting) { + if (!isWaiting) { return ProcessCompleted(Status.COMPLETED, event.eventId) + } else { + log.info { "Is waiting for task.." } } return null }