From fe3c238adb25ad669b4a4542e6d2dab1c3854d58 Mon Sep 17 00:00:00 2001 From: bskjon Date: Fri, 5 Jul 2024 01:02:06 +0200 Subject: [PATCH] Updated --- .../no/iktdev/mediaprocessing/converter/TaskCoordinator.kt | 2 ++ .../iktdev/mediaprocessing/converter/tasks/ConvertServiceV2.kt | 1 - 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/TaskCoordinator.kt b/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/TaskCoordinator.kt index daf48d73..f9d37139 100644 --- a/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/TaskCoordinator.kt +++ b/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/TaskCoordinator.kt @@ -15,6 +15,8 @@ class TaskCoordinator(): TaskCoordinatorBase() { private val log = KotlinLogging.logger {} override fun onCoordinatorReady() { super.onCoordinatorReady() + runnerManager = RunnerManager(dataSource = getEventsDatabase(), name = ConvertApplication::class.java.simpleName) + runnerManager.assignRunner() } diff --git a/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/tasks/ConvertServiceV2.kt b/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/tasks/ConvertServiceV2.kt index 78fe469c..f137448e 100644 --- a/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/tasks/ConvertServiceV2.kt +++ b/apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/tasks/ConvertServiceV2.kt @@ -17,7 +17,6 @@ import org.springframework.scheduling.annotation.EnableScheduling import org.springframework.stereotype.Service -@EnableScheduling @Service class ConvertServiceV2( @Autowired var tasks: TaskCoordinator,