diff --git a/CommonCode/src/main/java/no/iktdev/streamit/content/common/dto/reader/work/WorkBase.kt b/CommonCode/src/main/java/no/iktdev/streamit/content/common/dto/reader/work/WorkBase.kt
index a162ebcf..8b7a45eb 100644
--- a/CommonCode/src/main/java/no/iktdev/streamit/content/common/dto/reader/work/WorkBase.kt
+++ b/CommonCode/src/main/java/no/iktdev/streamit/content/common/dto/reader/work/WorkBase.kt
@@ -3,7 +3,7 @@ package no.iktdev.streamit.content.common.dto.reader.work
 import java.util.UUID
 
 abstract class WorkBase(
-    @Transient open val workId: String = UUID.randomUUID().toString(),
+    val workId: String = UUID.randomUUID().toString(),
     @Transient open val collection: String,
     @Transient open val inFile: String,
     @Transient open val outFile: String
diff --git a/Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt b/Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt
index f21c94ab..b2accbd5 100644
--- a/Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt
+++ b/Encode/src/main/kotlin/no/iktdev/streamit/content/encode/runner/RunnerCoordinator.kt
@@ -90,10 +90,12 @@ class RunnerCoordinator {
 
     val encodeListener = object: IEncodeListener {
         override fun onStarted(referenceId: String, work: EncodeWork) {
+            logger.info { "$referenceId with WorkId ${work.workId} @ ${work.outFile}: Started" }
             producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_VIDEO_FILE.event, Message(referenceId, Status(StatusType.SUCCESS), work))
         }
 
         override fun onError(referenceId: String, work: EncodeWork, code: Int) {
+            logger.info { "$referenceId with WorkId ${work.workId} @ ${work.outFile}: Error $code" }
             producer.sendMessage(KafkaEvents.EVENT_ENCODER_ENDED_VIDEO_FILE.event, Message(referenceId, Status(StatusType.ERROR, message = code.toString()), work))
         }
 
@@ -102,20 +104,24 @@ class RunnerCoordinator {
         }
 
         override fun onEnded(referenceId: String, work: EncodeWork) {
+            logger.info { "$referenceId with WorkId ${work.workId} @ ${work.outFile}: Ended" }
             producer.sendMessage(KafkaEvents.EVENT_ENCODER_ENDED_VIDEO_FILE.event, Message(referenceId, Status(StatusType.SUCCESS), work))
         }
     }
 
     val extractListener = object : IExtractListener {
         override fun onStarted(referenceId: String, work: ExtractWork) {
+            logger.info { "$referenceId with WorkId ${work.workId} @ ${work.outFile}: Started" }
             producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_SUBTITLE_FILE.event, Message(referenceId, Status(StatusType.SUCCESS), work))
         }
 
         override fun onError(referenceId: String, work: ExtractWork, code: Int) {
+            logger.info { "$referenceId with WorkId ${work.workId} @ ${work.outFile}: Error $code" }
             producer.sendMessage(KafkaEvents.EVENT_ENCODER_ENDED_SUBTITLE_FILE.event, Message(referenceId, Status(StatusType.ERROR), work))
         }
 
         override fun onEnded(referenceId: String, work: ExtractWork) {
+            logger.info { "$referenceId with WorkId ${work.workId} @ ${work.outFile}: Ended" }
             producer.sendMessage(KafkaEvents.EVENT_ENCODER_ENDED_SUBTITLE_FILE.event, Message(referenceId, Status(StatusType.SUCCESS), work))
         }