From ca2d4a17a4f03d940701cd0434fce4fdde3d9a74 Mon Sep 17 00:00:00 2001 From: gilesb Date: Tue, 13 Jan 2026 04:38:02 +0000 Subject: [PATCH] Fix: use DATABASE_URL instead of separate DB_* vars --- cache_manager.py | 25 +++---------------------- 1 file changed, 3 insertions(+), 22 deletions(-) diff --git a/cache_manager.py b/cache_manager.py index 1beb437..5b1d3cc 100644 --- a/cache_manager.py +++ b/cache_manager.py @@ -219,15 +219,8 @@ class L1CacheManager: import database async def save_to_db(): - # Create new connection for this thread import asyncpg - conn = await asyncpg.connect( - host=database.DB_HOST, - port=database.DB_PORT, - user=database.DB_USER, - password=database.DB_PASSWORD, - database=database.DB_NAME, - ) + conn = await asyncpg.connect(database.DATABASE_URL) try: await conn.execute( """ @@ -249,13 +242,7 @@ class L1CacheManager: async def get_from_db(): import asyncpg - conn = await asyncpg.connect( - host=database.DB_HOST, - port=database.DB_PORT, - user=database.DB_USER, - password=database.DB_PASSWORD, - database=database.DB_NAME, - ) + conn = await asyncpg.connect(database.DATABASE_URL) try: row = await conn.fetchrow( "SELECT ipfs_cid FROM cache_items WHERE cid = $1", @@ -276,13 +263,7 @@ class L1CacheManager: async def delete_from_db(): import asyncpg - conn = await asyncpg.connect( - host=database.DB_HOST, - port=database.DB_PORT, - user=database.DB_USER, - password=database.DB_PASSWORD, - database=database.DB_NAME, - ) + conn = await asyncpg.connect(database.DATABASE_URL) try: await conn.execute("DELETE FROM cache_items WHERE cid = $1", cache_id) finally: