From ae2887fdead1736b2704fa3ca8c621ab5c447d41 Mon Sep 17 00:00:00 2001 From: bskjon Date: Thu, 17 Oct 2024 03:02:31 +0200 Subject: [PATCH] Updated py --- 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 799cb055..efde61a9 100644 --- a/apps/pyMetadata/app.py +++ b/apps/pyMetadata/app.py @@ -111,12 +111,12 @@ class EventsPullerThread(threading.Thread): self.connection = None def run(self) -> None: - logger.info(f"Using {events_server_address}:{events_server_port} on table: {events_server_database_name}") + logger.info(f"Using {events_server_address}:{events_server_port} on table: {events_server_database_name} with user: {events_server_username}") while not self.shutdown.is_set(): producedMessage: bool = False while not self.shutdown.is_set(): - if self.connection is None or not self.connection.is_connected(): + if (self.connection == None or not self.connection.is_connected()): logging.info("Attempting to reconnect to the database...") self.__connect_to_datasource()