diff --git a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/CoordinatorClient.kt b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/CoordinatorClient.kt index d2e59ceb..e9b21aab 100644 --- a/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/CoordinatorClient.kt +++ b/apps/processer/src/main/kotlin/no/iktdev/mediaprocessing/processer/CoordinatorClient.kt @@ -42,4 +42,8 @@ class CoordinatorClient( .bodyValue(ProgressUpdate(referenceId, taskId, percent, message)) .retrieve() .toBodilessEntity() + .doOnSuccess { log.info { "Progress sent" } } + .doOnError { e -> log.error(e) { "Failed to send progress" } } + .subscribe() + }