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 308dbf25..a83e2952 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
@@ -53,6 +53,8 @@ class RunnerCoordinator {
             } catch (e: Exception) {
                 e.printStackTrace()
                 producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_VIDEO_FILE.event, message.withNewStatus(Status(StatusType.ERROR, e.message)))
+            } finally {
+                semaphore.release()
             }
 
         }
@@ -74,6 +76,8 @@ class RunnerCoordinator {
             } catch (e: Exception) {
                 e.printStackTrace()
                 producer.sendMessage(KafkaEvents.EVENT_ENCODER_STARTED_SUBTITLE_FILE.event, message.withNewStatus(Status(StatusType.ERROR, e.message)))
+            } finally {
+                semaphore.release()
             }
         }
     }