This commit is contained in:
bskjon 2024-04-17 03:13:24 +02:00
parent 80a7d3e706
commit 3b8ce8f86a

View File

@ -93,8 +93,8 @@ class PersistentEventManager(private val dataSource: DataSource) {
fun getEventsUncompleted(): List<List<PersistentMessage>> {
val identifiesAsCompleted = listOf(
KafkaEvents.EventRequestProcessCompleted,
KafkaEvents.EventMediaProcessCompleted,
/*KafkaEvents.EventRequestProcessCompleted,
KafkaEvents.EventMediaProcessCompleted,*/
KafkaEvents.EventCollectAndStore
)
val all = getAllEventsGrouped()