diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CoverFromMetadataTaskListener.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CoverFromMetadataTaskListener.kt
index 9ea75ed7..75b3a3ab 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CoverFromMetadataTaskListener.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CoverFromMetadataTaskListener.kt
@@ -53,7 +53,7 @@ class CoverFromMetadataTaskListener: CoordinatorEventListener() {
 
         val metadata = events.findLast { it.eventType == Events.EventMediaMetadataSearchPerformed }?.az<MediaMetadataReceivedEvent>()?.data
         if (metadata == null) {
-            log.info { "No metadata.." }
+            //log.info { "No metadata.." }
             return
         }
         val mediaOutInfo = events.find { it.eventType == Events.EventMediaReadOutNameAndType }?.az<MediaOutInformationConstructedEvent>()?.data
diff --git a/apps/pyMetadata/app.py b/apps/pyMetadata/app.py
index b0e5ad48..b8ada766 100644
--- a/apps/pyMetadata/app.py
+++ b/apps/pyMetadata/app.py
@@ -52,11 +52,11 @@ class EventsPullerThread(threading.Thread):
         self.shutdown = threading.Event()
 
     def run(self) -> None:
+        logger.info(f"Using {events_server_address}:{events_server_port} on table: {events_server_database_name}")
         while not self.shutdown.is_set():
             connection = None
             cursor = None
             try:
-                logger.info(f"Connecting to {events_server_address}:{events_server_port} on table: {events_server_database_name}")
                 connection = mysql.connector.connect(
                     host=events_server_address,
                     port=events_server_port,
@@ -66,13 +66,18 @@ class EventsPullerThread(threading.Thread):
                 )
                 cursor = connection.cursor(dictionary=True)
                 cursor.execute("""
-                                    SELECT e1.*
-                                    FROM events e1
-                                    LEFT JOIN events e2 
-                                        ON e1.referenceId = e2.referenceId 
-                                        AND e2.event = 'event:media-metadata-search:performed'
-                                    WHERE e1.event = 'event:media-read-base-info:performed'
-                                    AND e2.referenceId IS NULL;
+                                    SELECT *
+                                    FROM events
+                                    WHERE referenceId IN (
+                                        SELECT referenceId
+                                        FROM events
+                                        GROUP BY referenceId
+                                        HAVING 
+                                            SUM(event = 'event:media-read-base-info:performed') > 0
+                                            AND SUM(event = 'event:media-metadata-search:performed') = 0
+                                            AND SUM(event = 'event:media-process:completed') = 0
+                                    )
+                                    AND event = 'event:media-read-base-info:performed';
                                """)
                 # not event:media-metadata-search:performed
                 for row in cursor.fetchall():