diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CompletedTaskListener.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CompletedTaskListener.kt index fb4de14b..57bab0b7 100644 --- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CompletedTaskListener.kt +++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CompletedTaskListener.kt @@ -108,7 +108,7 @@ class CompletedTaskListener : CoordinatorEventListener() { override fun shouldIProcessAndHandleEvent(incomingEvent: Event, events: List): Boolean { val result = super.shouldIProcessAndHandleEvent(incomingEvent, events) - return result + return result && events.any { it.eventType == Events.PersistContentPerformed } } override fun onEventsReceived(incomingEvent: ConsumableEvent, events: List) {