diff --git a/Reader/build.gradle.kts b/Reader/build.gradle.kts
index 8d718826..98fe4c02 100644
--- a/Reader/build.gradle.kts
+++ b/Reader/build.gradle.kts
@@ -27,7 +27,7 @@ dependencies {
     implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha75")
     implementation("no.iktdev:exfl:0.0.12-SNAPSHOT")
 
-    implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha11")
+    implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha12")
 
     implementation("org.jetbrains.exposed:exposed-core:$exposedVersion")
     implementation("org.jetbrains.exposed:exposed-dao:$exposedVersion")
diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt
index 775bcb70..da7194b3 100644
--- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt
+++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt
@@ -18,6 +18,7 @@ import org.jetbrains.exposed.sql.insert
 import org.jetbrains.exposed.sql.transactions.transaction
 import org.springframework.stereotype.Service
 import java.io.File
+import kotlin.math.log
 
 private val logger = KotlinLogging.logger {}
 
@@ -63,11 +64,18 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle
         val videoFileNameWithExtension = File(encodeWork.outFile).name
 
         val iid = transaction {
-            val serieStatus = if (serieData != null) {
-                getSerieQueryInstance(serieData, videoFileNameWithExtension)?.insertAndGetStatus() ?: false
-            } else true
+            if (serieData != null) {
+                val serieInsertStatus = getSerieQueryInstance(serieData, videoFileNameWithExtension)?.insertAndGetStatus()
+                if (serieInsertStatus == false) {
+                    logger.warn { "Failed to insert episode $videoFileNameWithExtension" }
+                }
+            }
             if (serieData == null || metadata?.type == "movie") {
-                MovieQuery(videoFileNameWithExtension).insertAndGetId()
+                val iid = MovieQuery(videoFileNameWithExtension).insertAndGetId()
+                if (iid == null) {
+                    logger.warn { "Failed to insert movie and get id for it $videoFileNameWithExtension" }
+                }
+                iid
             } else null
         }