Removing database closer
This commit is contained in:
parent
639b205376
commit
e25d0d4e9e
@ -186,10 +186,7 @@ Producing message
|
||||
|
||||
except mysql.connector.Error as err:
|
||||
logger.error("Database error: %s", err)
|
||||
finally:
|
||||
if self.connection:
|
||||
self.connection.close()
|
||||
self.connection = None
|
||||
|
||||
# Introduce a small sleep to reduce CPU usage
|
||||
time.sleep(2)
|
||||
if (self.shutdown.is_set()):
|
||||
|
||||
Loading…
Reference in New Issue
Block a user