diff --git a/apps/pyMetadata/app.py b/apps/pyMetadata/app.py
index efde61a9..1c05f727 100644
--- a/apps/pyMetadata/app.py
+++ b/apps/pyMetadata/app.py
@@ -50,6 +50,9 @@ logging.basicConfig(
 logger = logging.getLogger(__name__)
 
 class EventsPullerThread(threading.Thread):
+    
+    connection: PooledMySQLConnection | MySQLConnectionAbstract | None = None
+    
     def __init__(self):
         super().__init__()
         self.shutdown = threading.Event()