From 7fc45625bdf70a6b861ca52e32aa76c5ccb08903 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Brage=20Skj=C3=B8nborg?= Date: Sun, 1 Feb 2026 02:15:34 +0100 Subject: [PATCH] Correcting abandoned --- .../shared/common/rules/TaskLifecycleRules.kt | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/rules/TaskLifecycleRules.kt b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/rules/TaskLifecycleRules.kt index 15180b54..9e309a97 100644 --- a/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/rules/TaskLifecycleRules.kt +++ b/shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/rules/TaskLifecycleRules.kt @@ -11,14 +11,18 @@ object TaskLifecycleRules { fun isAbandoned( consumed: Boolean, + createdAt: Instant, lastCheckIn: Instant? ): Boolean { if (consumed) return false val cutoff = Instant.now().minus(abandonedAfterMinutes, ChronoUnit.MINUTES) - return lastCheckIn == null || lastCheckIn.isBefore(cutoff) + + val reference = lastCheckIn ?: createdAt + return reference.isBefore(cutoff) } + fun isStalled(task: PersistedTask): Boolean { if (task.consumed) return false