iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

logging

Browse Source
This commit is contained in:
bskjon 2025-04-27 11:35:20 +02:00
parent 421afb8096
commit 7f79eb1e26
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/converter/src/main/kotlin/no/iktdev/mediaprocessing/converter/TaskCoordinator.kt
View File

@ -49,7 +49,11 @@ class TaskCoordinator(): TaskCoordinatorBase() {
override fun pullForAvailableTasks() { override fun pullForAvailableTasks() {
if (runnerManager.iAmSuperseded()) { if (runnerManager.iAmSuperseded()) {
// This will let the application complete but not consume new // This will let the application complete but not consume new
val prevState = taskMode
taskMode = ActiveMode.Passive 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 return
} }
val available = taskManager.getClaimableTasks().asClaimable() val available = taskManager.getClaimableTasks().asClaimable()

4
apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/TaskCoordinator.kt
View File

@ -51,7 +51,11 @@ class TaskCoordinator(): TaskCoordinatorBase() {
override fun pullForAvailableTasks() { override fun pullForAvailableTasks() {
if (runnerManager.iAmSuperseded()) { if (runnerManager.iAmSuperseded()) {
// This will let the application complete but not consume new // This will let the application complete but not consume new
val prevState = taskMode
taskMode = ActiveMode.Passive 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 return
} }
val available = taskManager.getClaimableTasks().asClaimable() val available = taskManager.getClaimableTasks().asClaimable()