From 49a88bcbaf46d7dee56788f406a6ddbc6d4e29f6 Mon Sep 17 00:00:00 2001
From: bskjon <bskjon@outlook.com>
Date: Wed, 18 Dec 2024 21:39:43 +0100
Subject: [PATCH] Closing connection after every query

---
 apps/pyMetadata/app.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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