diff --git a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/persistance/PersistentEventManager.kt b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/persistance/PersistentEventManager.kt index 037327f8..1e9b2acb 100644 --- a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/persistance/PersistentEventManager.kt +++ b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/persistance/PersistentEventManager.kt @@ -93,8 +93,8 @@ class PersistentEventManager(private val dataSource: DataSource) { fun getEventsUncompleted(): List> { val identifiesAsCompleted = listOf( - KafkaEvents.EventRequestProcessCompleted, - KafkaEvents.EventMediaProcessCompleted, + /*KafkaEvents.EventRequestProcessCompleted, + KafkaEvents.EventMediaProcessCompleted,*/ KafkaEvents.EventCollectAndStore ) val all = getAllEventsGrouped()