iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fixed logging

Browse Source
This commit is contained in:
bskjon 2025-02-22 15:55:32 +01:00
parent 5c04c368d8
commit 31438544ac
2 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/coordinator/src/main/kotlin/no/iktdev/mediaprocessing/coordinator/tasksV2/listeners/CompletedTaskListener.kt
View File

@ -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
}

7
apps/pyMetadata/app.py
View File

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