diff --git a/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/Task.kt b/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/Task.kt index 8b15eea5..d289e085 100644 --- a/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/Task.kt +++ b/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/Task.kt @@ -39,4 +39,9 @@ abstract class TaskCreator(coordinator: ConverterCoordinator) : override fun prerequisiteRequired(event: PersistentProcessDataMessage): List<() -> Boolean> { return listOf() } + + override fun containsUnprocessedEvents(events: List): Boolean { + return true + } + } \ No newline at end of file diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt index 22312561..1fb34da5 100644 --- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt +++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/Task.kt @@ -37,4 +37,8 @@ abstract class TaskCreator(coordinator: Coordinator) : override fun prerequisiteRequired(event: PersistentProcessDataMessage): List<() -> Boolean> { return listOf() } + + override fun containsUnprocessedEvents(events: List): Boolean { + return true + } } \ No newline at end of file