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

v3 13

Browse Source
This commit is contained in:
bskjon 2024-07-14 00:52:27 +02:00
parent 63622d6a1f
commit cd8cda3c23
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/pyMetadata/app.py
View File

@ -78,7 +78,7 @@ class EventsPullerThread(threading.Thread):
for row in cursor.fetchall(): for row in cursor.fetchall():
if self.shutdown.is_set(): if self.shutdown.is_set():
break break
logger.debug(row) logger.info("Event found!")
handler_thread = MessageHandlerThread(row) handler_thread = MessageHandlerThread(row)
handler_thread.start() handler_thread.start()
@ -103,8 +103,10 @@ class MessageHandlerThread(threading.Thread):
def __init__(self, row): def __init__(self, row):
super().__init__() super().__init__()
self.mediaEvent = json_to_media_event(json.loads(row['data'])) self.mediaEvent = json_to_media_event(json.loads(row['data']))
logger.info(self.mediaEvent)
def run(self): def run(self):
logger.info("Starting processing")
if (self.mediaEvent is None): if (self.mediaEvent is None):
logger.error("Event does not contain anything...") logger.error("Event does not contain anything...")
return return