From 7f79eb1e262a674af1f328d7d874790877e917c9 Mon Sep 17 00:00:00 2001 From: bskjon Date: Sun, 27 Apr 2025 11:35:20 +0200 Subject: [PATCH] logging --- .../no/iktdev/mediaprocessing/converter/TaskCoordinator.kt | 4 ++++ .../no/iktdev/mediaprocessing/processer/TaskCoordinator.kt | 4 ++++ 2 files changed, 8 insertions(+) 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()