From 50aebda69e514ed662577828db4c72ae245b1c2f Mon Sep 17 00:00:00 2001
From: bskjon <bskjon@outlook.com>
Date: Sun, 30 Jun 2024 02:44:47 +0200
Subject: [PATCH] Table

---
 .../iktdev/mediaprocessing/converter/ConverterApplication.kt   | 3 ++-
 .../mediaprocessing/coordinator/CoordinatorApplication.kt      | 3 ++-
 .../iktdev/mediaprocessing/processer/ProcesserApplication.kt   | 2 +-
 3 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/ConverterApplication.kt b/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/ConverterApplication.kt
index 018c08ed..a1ea46cb 100644
--- a/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/ConverterApplication.kt
+++ b/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/ConverterApplication.kt
@@ -9,6 +9,7 @@ import no.iktdev.mediaprocessing.shared.common.datasource.MySqlDataSource
 import no.iktdev.mediaprocessing.shared.common.getAppVersion
 import no.iktdev.mediaprocessing.shared.common.persistance.PersistentEventManager
 import no.iktdev.mediaprocessing.shared.common.persistance.TasksManager
+import no.iktdev.mediaprocessing.shared.common.persistance.runners
 import no.iktdev.mediaprocessing.shared.common.persistance.tasks
 import no.iktdev.mediaprocessing.shared.common.toEventsDatabase
 import org.springframework.boot.autoconfigure.SpringBootApplication
@@ -50,7 +51,7 @@ fun main(args: Array<String>) {
 
     eventsDatabase = DatabaseEnvConfig.toEventsDatabase()
     eventsDatabase.createDatabase()
-    eventsDatabase.createTables(tasks)
+    eventsDatabase.createTables(tasks, runners)
     taskManager = TasksManager(eventsDatabase)
 
     context = runApplication<ConvertApplication>(*args)
diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/CoordinatorApplication.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/CoordinatorApplication.kt
index c34cc7b8..884e88ca 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/CoordinatorApplication.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/CoordinatorApplication.kt
@@ -73,7 +73,8 @@ fun main(args: Array<String>) {
     val kafkaTables = listOf(
         events, // For kafka
         allEvents,
-        tasks
+        tasks,
+        runners
     )
 
 
diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/ProcesserApplication.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/ProcesserApplication.kt
index c0582f73..ec30c4a0 100644
--- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/ProcesserApplication.kt
+++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/ProcesserApplication.kt
@@ -50,7 +50,7 @@ fun main(args: Array<String>) {
 
     eventsDatabase = DatabaseEnvConfig.toEventsDatabase()
     eventsDatabase.createDatabase()
-    eventsDatabase.createTables(tasks)
+    eventsDatabase.createTables(tasks, runners)
 
     taskManager = TasksManager(eventsDatabase)