From 31438544acbc87d1788557c30d3c0b72306da1c1 Mon Sep 17 00:00:00 2001
From: bskjon <bskjon@outlook.com>
Date: Sat, 22 Feb 2025 15:55:32 +0100
Subject: [PATCH] Fixed logging

---
 .../coordinator/tasksV2/listeners/CompletedTaskListener.kt | 4 ----
 apps/pyMetadata/app.py                                     | 7 +++++++
 2 files changed, 7 insertions(+), 4 deletions(-)

diff --git a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CompletedTaskListener.kt b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CompletedTaskListener.kt
index b5400852..5cfa714c 100644
--- a/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CompletedTaskListener.kt
+++ b/apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CompletedTaskListener.kt
@@ -189,14 +189,12 @@ class CompletedTaskListener : CoordinatorEventListener() {
             e.printStackTrace()
         }
 
-
         ProcessedFileStore.store(
             mediaInfo.title,
             events,
             EventsSummaryMapping().map(events)
         )
 
-
         if (!doNotProduceComplete) {
             onProduceEvent(MediaProcessCompletedEvent(
                 metadata = event.makeDerivedEventInfo(EventStatus.Success, getProducerName()),
@@ -206,8 +204,6 @@ class CompletedTaskListener : CoordinatorEventListener() {
             log.warn { "Do not produce complete is enabled!" }
         }
 
-
-
         active = false
     }
 
diff --git a/apps/pyMetadata/app.py b/apps/pyMetadata/app.py
index 4075f589..7a1dfded 100644
--- a/apps/pyMetadata/app.py
+++ b/apps/pyMetadata/app.py
@@ -175,6 +175,12 @@ class EventsPullerThread(threading.Thread):
                     if (row is not None):
                         try:
                             referenceId = row["referenceId"]
+                            status = row["status"]
+                            
+                            if (status == "Failed" or status == "Skipped"):
+                                logger.info(f"Skipping failed event referenceId: {referenceId}, eventId: {row['eventId']}")
+                                continue
+                            
                             incomingEventType = row["event"]
                             logMessage = f"""
 ============================================================================
@@ -184,6 +190,7 @@ Found message
 ============================================================================\n"""
                             logger.info(logMessage)
                             
+                            
                             event = json_to_media_event(row["data"])
                             producedEvent = asyncio.run(MetadataEventHandler(event).run())