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

Updated py

Browse Source
This commit is contained in:
bskjon 2024-10-17 03:02:31 +02:00
parent 15e719fe8e
commit ae2887fdea
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

@ -111,12 +111,12 @@ class EventsPullerThread(threading.Thread):
self.connection = None self.connection = None
def run(self) -> 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(): while not self.shutdown.is_set():
producedMessage: bool = False producedMessage: bool = False
while not self.shutdown.is_set(): 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...") logging.info("Attempting to reconnect to the database...")
self.__connect_to_datasource() self.__connect_to_datasource()