Updated check
This commit is contained in:
parent
7cd4591bf1
commit
2020022b13
@ -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
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user