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,