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 d8cd2776..63f81688 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
@@ -71,7 +71,7 @@ class RunnerCoordinator(private var maxConcurrentJobs: Int = 1) {
     private suspend fun processWorkItem(workItem: ExecutionBlock): Job {
         logger.info { "Processing work: ${workItem.type}" }
         workItem.work()
-        return Job()
+        return Job().apply { complete() }
     }