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

v3 12

Browse Source
This commit is contained in:
bskjon 2024-07-14 00:48:09 +02:00
parent 0d38a75797
commit 63622d6a1f
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/pyMetadata/app.py
View File

@ -56,6 +56,7 @@ class EventsPullerThread(threading.Thread):
connection = None connection = None
cursor = None cursor = None
try: try:
logger.info(f"Connecting to {events_server_address}:{events_server_port} on table: {events_server_database_name}")
connection = mysql.connector.connect( connection = mysql.connector.connect(
host=events_server_address, host=events_server_address,
port=events_server_port, port=events_server_port,
@ -77,6 +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)
handler_thread = MessageHandlerThread(row) handler_thread = MessageHandlerThread(row)
handler_thread.start() handler_thread.start()