slipstream/discordbot
slipstream/discordbot
1
1
Fork 0
Code Issues Pull Requests 3 Actions Packages Projects Releases Wiki Activity

a

Browse Source
This commit is contained in:
Slipstream 2025-05-06 17:01:07 -06:00
parent 723f96909d
commit b6d131beba
Signed by: slipstream
GPG Key ID: 13E498CE010AC6FD
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
settings_manager.py
View File

@ -67,13 +67,15 @@ async def initialize_pools(event_loop=None): # Add event_loop parameter
else: else:
log.info(f"initialize_pools called without event_loop. Current executing loop: {current_executing_loop}.") log.info(f"initialize_pools called without event_loop. Current executing loop: {current_executing_loop}.")
# Use the correct event loop for asyncpg pool creation to avoid cross-loop issues
loop_to_use = event_loop or asyncio.get_event_loop()
pg_pool = await asyncpg.create_pool( pg_pool = await asyncpg.create_pool(
DATABASE_URL, DATABASE_URL,
min_size=1, min_size=1,
max_size=10, max_size=10,
command_timeout=30.0, # 30 seconds timeout for commands command_timeout=30.0, # 30 seconds timeout for commands
max_inactive_connection_lifetime=300 # Refresh idle connections after 5 minutes max_inactive_connection_lifetime=300, # Refresh idle connections after 5 minutes
# No loop parameter, asyncpg uses the current running loop loop=loop_to_use
) )
log.info(f"PostgreSQL pool created for {POSTGRES_HOST}/{POSTGRES_DB}. Loop during creation: {asyncio.get_event_loop()}") log.info(f"PostgreSQL pool created for {POSTGRES_HOST}/{POSTGRES_DB}. Loop during creation: {asyncio.get_event_loop()}")