This commit is contained in:
parent
14b1c7f82d
commit
3a722eca04
@ -39,7 +39,7 @@ def create_connection_pool():
|
|||||||
try:
|
try:
|
||||||
logger.info(f"[MySQL] Attempt {attempt} to connect...")
|
logger.info(f"[MySQL] Attempt {attempt} to connect...")
|
||||||
pool = pooling.MySQLConnectionPool(
|
pool = pooling.MySQLConnectionPool(
|
||||||
pool_name="royalroadPool",
|
pool_name="repositoryQueryPool",
|
||||||
pool_size=5,
|
pool_size=5,
|
||||||
pool_reset_session=True,
|
pool_reset_session=True,
|
||||||
**MYSQL_CONFIG
|
**MYSQL_CONFIG
|
||||||
@ -101,7 +101,6 @@ def _pool_healthcheck():
|
|||||||
conn = pool.get_connection()
|
conn = pool.get_connection()
|
||||||
conn.ping(reconnect=True, attempts=3, delay=1)
|
conn.ping(reconnect=True, attempts=3, delay=1)
|
||||||
conn.close()
|
conn.close()
|
||||||
logger.debug("[MySQL] Pool healthcheck OK.")
|
|
||||||
except Error as e:
|
except Error as e:
|
||||||
logger.warning(f"[MySQL] Pool healthcheck failed: {e}")
|
logger.warning(f"[MySQL] Pool healthcheck failed: {e}")
|
||||||
create_connection_pool()
|
create_connection_pool()
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user