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

Closing connection after every query

Browse Source
This commit is contained in:
bskjon 2024-12-18 21:39:43 +01:00
parent 01df7ef239
commit 49a88bcbaf
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/pyMetadata/app.py
View File

@ -218,12 +218,12 @@ Producing message
self.storeProducedEvent(connection=self.connection, event=producedEvent) self.storeProducedEvent(connection=self.connection, event=producedEvent)
except Exception as iex: except Exception as iex:
logger.error("Failed to push error to database..") logger.error("Failed to push error to database..")
self.connection.close()
except mysql.connector.Error as err: except mysql.connector.Error as err:
logger.error("Database error: %s", err) logger.error("Database error: %s", err)
# Introduce a small sleep to reduce CPU usage # Introduce a small sleep to reduce CPU usage
time.sleep(2) time.sleep(5)
if (self.shutdown.is_set()): if (self.shutdown.is_set()):
logger.info("Shutdown is set..") logger.info("Shutdown is set..")
logging.debug("End of puller function..") logging.debug("End of puller function..")