diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/implementations/WorkTaskListener.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/implementations/WorkTaskListener.kt index b7b8c573..834f686d 100644 --- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/implementations/WorkTaskListener.kt +++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/implementations/WorkTaskListener.kt @@ -15,6 +15,9 @@ abstract class WorkTaskListener: CoordinatorEventListener() { private val log = KotlinLogging.logger {} override fun shouldIProcessAndHandleEvent(incomingEvent: Event, events: List): Boolean { + if (!super.shouldIProcessAndHandleEvent(incomingEvent, events)) { + return false + } return canStart(incomingEvent, events) }