From 4f3be9a642381ea9dc423d006a01d2454287a82a Mon Sep 17 00:00:00 2001 From: Brage Date: Mon, 25 Mar 2024 18:21:17 +0100 Subject: [PATCH] Updated --- .../coordinator/tasks/event/CompleteMediaTask.kt | 2 +- .../coordinator/tasks/event/CompleteRequestTask.kt | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteMediaTask.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteMediaTask.kt index ae86ab0c..ce00d43b 100644 --- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteMediaTask.kt +++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteMediaTask.kt @@ -48,7 +48,7 @@ class CompleteMediaTask(@Autowired override var coordinator: Coordinator) : Task if (requiresOneOf.none { it in receivedEvents }) { val missing = requiresOneOf.filter { !receivedEvents.contains(it) } - log.info { "Can't complete at this moment. Missing required event(s)" + missing.joinToString("\n\t") } + log.info { "Can't complete at this moment. Missing required event(s)\n\t" + missing.joinToString("\n\t") } return null //SimpleMessageData(Status.SKIPPED, "Can't collect at this moment. Missing required event") } diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteRequestTask.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteRequestTask.kt index 1551ab73..01970bc6 100644 --- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteRequestTask.kt +++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasks/event/CompleteRequestTask.kt @@ -29,7 +29,7 @@ class CompleteRequestTask(@Autowired override var coordinator: Coordinator) : Ta override fun onProcessEvents(event: PersistentMessage, events: List): MessageDataWrapper? { - val started = events.lastOrSuccessOf(EVENT_MEDIA_PROCESS_STARTED) ?: return null + val started = events.lastOrSuccessOf(EVENT_REQUEST_PROCESS_STARTED) ?: return null if (!started.data.isSuccess()) { return null }