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

Correcting abandoned

Browse Source
This commit is contained in:
Brage Skjønborg 2026-02-01 02:15:34 +01:00
parent f00c45d38b
commit 7fc45625bd
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
shared/common/src/main/kotlin/no/iktdev/mediaprocessing/shared/common/rules/TaskLifecycleRules.kt
View File

@ -11,14 +11,18 @@ object TaskLifecycleRules {
fun isAbandoned( fun isAbandoned(
consumed: Boolean, consumed: Boolean,
createdAt: Instant,
lastCheckIn: Instant? lastCheckIn: Instant?
): Boolean { ): Boolean {
if (consumed) return false if (consumed) return false
val cutoff = Instant.now().minus(abandonedAfterMinutes, ChronoUnit.MINUTES) 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 { fun isStalled(task: PersistedTask): Boolean {
if (task.consumed) return false if (task.consumed) return false