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 7763f2cc..5114e81c 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 @@ -49,7 +49,11 @@ class TaskCoordinator(): TaskCoordinatorBase() { override fun pullForAvailableTasks() { if (runnerManager.iAmSuperseded()) { // This will let the application complete but not consume new + val prevState = taskMode taskMode = ActiveMode.Passive + if (taskMode != prevState && taskMode == ActiveMode.Passive) { + log.warn { "A newer version has been detected. Changing mode to $taskMode, no new tasks will be processed" } + } return } val available = taskManager.getClaimableTasks().asClaimable() diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/TaskCoordinator.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/TaskCoordinator.kt index d39fbe75..7b514eb3 100644 --- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/TaskCoordinator.kt +++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/TaskCoordinator.kt @@ -51,7 +51,11 @@ class TaskCoordinator(): TaskCoordinatorBase() { override fun pullForAvailableTasks() { if (runnerManager.iAmSuperseded()) { // This will let the application complete but not consume new + val prevState = taskMode taskMode = ActiveMode.Passive + if (taskMode != prevState && taskMode == ActiveMode.Passive) { + log.warn { "A newer version has been detected. Changing mode to $taskMode, no new tasks will be processed" } + } return } val available = taskManager.getClaimableTasks().asClaimable()