From 27372f37e5ccf22a23adaa80d2a42c2fd7a7f9a1 Mon Sep 17 00:00:00 2001
From: Brage <bskjon@outlook.com>
Date: Tue, 25 Jul 2023 23:14:09 +0200
Subject: [PATCH] Updated encode runner

---
 .../streamit/content/encode/runner/RunnerCoordinator.kt       | 4 ++++
 1 file changed, 4 insertions(+)

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()
             }
         }
     }