From accce27eb65bfac7805afad76aff6750b12063e3 Mon Sep 17 00:00:00 2001 From: bskjon Date: Mon, 19 Aug 2024 00:01:52 +0200 Subject: [PATCH] Fix --- .../iktdev/mediaprocessing/coordinator/EventsDatabase.kt | 8 +++----- .../iktdev/mediaprocessing/coordinator/utils/TasksUtil.kt | 1 - 2 files changed, 3 insertions(+), 6 deletions(-) diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/EventsDatabase.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/EventsDatabase.kt index 4ca631e1..c7e0045c 100644 --- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/EventsDatabase.kt +++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/EventsDatabase.kt @@ -1,10 +1,7 @@ package no.iktdev.mediaprocessing.coordinator import no.iktdev.mediaprocessing.shared.common.DatabaseEnvConfig -import no.iktdev.mediaprocessing.shared.common.database.tables.allEvents -import no.iktdev.mediaprocessing.shared.common.database.tables.events -import no.iktdev.mediaprocessing.shared.common.database.tables.runners -import no.iktdev.mediaprocessing.shared.common.database.tables.tasks +import no.iktdev.mediaprocessing.shared.common.database.tables.* import no.iktdev.mediaprocessing.shared.common.toEventsDatabase class EventsDatabase() { @@ -13,7 +10,8 @@ class EventsDatabase() { events, // For kafka allEvents, tasks, - runners + runners, + processed ) init { diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/utils/TasksUtil.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/utils/TasksUtil.kt index 2c62640b..8516ef7d 100644 --- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/utils/TasksUtil.kt +++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/utils/TasksUtil.kt @@ -1,7 +1,6 @@ package no.iktdev.mediaprocessing.coordinator.utils import mu.KotlinLogging -import no.iktdev.mediaprocessing.shared.common.persistance.* import no.iktdev.mediaprocessing.shared.common.task.TaskType import no.iktdev.mediaprocessing.shared.common.contract.data.Event