Update
This commit is contained in:
parent
7c25437a10
commit
6b5c115a2c
@ -22,10 +22,6 @@ abstract class CreateProcesserWorkTask(override var coordinator: Coordinator) :
|
||||
return null
|
||||
}
|
||||
|
||||
if (!event.data.isSuccess()) {
|
||||
return null
|
||||
}
|
||||
|
||||
val proceed = events.find { it.event == KafkaEvents.EventMediaWorkProceedPermitted }
|
||||
if (proceed == null && started.type == ProcessType.MANUAL) {
|
||||
log.warn { "${event.referenceId} waiting for Proceed event due to Manual process" }
|
||||
|
||||
Loading…
Reference in New Issue
Block a user