Changed check
This commit is contained in:
parent
1d7f78bfea
commit
849c4d1df4
@ -46,8 +46,9 @@ class CompleteTask(@Autowired override var coordinator: Coordinator) : TaskCreat
|
|||||||
EVENT_WORK_ENCODE_PERFORMED
|
EVENT_WORK_ENCODE_PERFORMED
|
||||||
)
|
)
|
||||||
|
|
||||||
if (!requiresOneOf.any { it in receivedEvents }) {
|
if (requiresOneOf.none { it in receivedEvents }) {
|
||||||
log.info { "Can't complete at this moment. Missing required event" }
|
val missing = requiresOneOf.filter { !receivedEvents.contains(it) }
|
||||||
|
log.info { "Can't complete at this moment. Missing required event(s)" + missing.joinToString("\n\t") }
|
||||||
return null //SimpleMessageData(Status.SKIPPED, "Can't collect at this moment. Missing required event")
|
return null //SimpleMessageData(Status.SKIPPED, "Can't collect at this moment. Missing required event")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user