art-dag/celery
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix: use DATABASE_URL instead of separate DB_* vars

Browse Source
This commit is contained in:
gilesb
2026-01-13 04:38:02 +00:00
parent 4f3eccd4d3
commit ca2d4a17a4
1 changed files with 3 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
cache_manager.py
View File

@@ -219,15 +219,8 @@ class L1CacheManager:
import database import database
async def save_to_db(): async def save_to_db():
# Create new connection for this thread
import asyncpg import asyncpg
conn = await asyncpg.connect( conn = await asyncpg.connect(database.DATABASE_URL)
host=database.DB_HOST,
port=database.DB_PORT,
user=database.DB_USER,
password=database.DB_PASSWORD,
database=database.DB_NAME,
)
try: try:
await conn.execute( await conn.execute(
""" """
@@ -249,13 +242,7 @@ class L1CacheManager:
async def get_from_db(): async def get_from_db():
import asyncpg import asyncpg
conn = await asyncpg.connect( conn = await asyncpg.connect(database.DATABASE_URL)
host=database.DB_HOST,
port=database.DB_PORT,
user=database.DB_USER,
password=database.DB_PASSWORD,
database=database.DB_NAME,
)
try: try:
row = await conn.fetchrow( row = await conn.fetchrow(
"SELECT ipfs_cid FROM cache_items WHERE cid = $1", "SELECT ipfs_cid FROM cache_items WHERE cid = $1",
@@ -276,13 +263,7 @@ class L1CacheManager:
async def delete_from_db(): async def delete_from_db():
import asyncpg import asyncpg
conn = await asyncpg.connect( conn = await asyncpg.connect(database.DATABASE_URL)
host=database.DB_HOST,
port=database.DB_PORT,
user=database.DB_USER,
password=database.DB_PASSWORD,
database=database.DB_NAME,
)
try: try:
await conn.execute("DELETE FROM cache_items WHERE cid = $1", cache_id) await conn.execute("DELETE FROM cache_items WHERE cid = $1", cache_id)
finally: finally: