This commit is contained in:
bskjon 2024-07-05 01:02:06 +02:00
parent 31a47405df
commit fe3c238adb
2 changed files with 2 additions and 1 deletions

View File

@ -15,6 +15,8 @@ class TaskCoordinator(): TaskCoordinatorBase() {
private val log = KotlinLogging.logger {} private val log = KotlinLogging.logger {}
override fun onCoordinatorReady() { override fun onCoordinatorReady() {
super.onCoordinatorReady() super.onCoordinatorReady()
runnerManager = RunnerManager(dataSource = getEventsDatabase(), name = ConvertApplication::class.java.simpleName)
runnerManager.assignRunner()
} }

View File

@ -17,7 +17,6 @@ import org.springframework.scheduling.annotation.EnableScheduling
import org.springframework.stereotype.Service import org.springframework.stereotype.Service
@EnableScheduling
@Service @Service
class ConvertServiceV2( class ConvertServiceV2(
@Autowired var tasks: TaskCoordinator, @Autowired var tasks: TaskCoordinator,