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

Missing call

Browse Source
This commit is contained in:
Brage Skjønborg 2026-02-02 01:10:35 +01:00
parent 35111ad7fa
commit 14633fe72c
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -42,4 +42,8 @@ class CoordinatorClient(
.bodyValue(ProgressUpdate(referenceId, taskId, percent, message)) .bodyValue(ProgressUpdate(referenceId, taskId, percent, message))
.retrieve() .retrieve()
.toBodilessEntity() .toBodilessEntity()
.doOnSuccess { log.info { "Progress sent" } }
.doOnError { e -> log.error(e) { "Failed to send progress" } }
.subscribe()
} }