fix delete with pooler

This commit is contained in:
Nicolò Boschi 2025-12-04 21:36:46 +01:00
parent 06b956a553
commit f7884f5e2f

View file

@ -1689,6 +1689,8 @@ class MemoryEngine:
"""
pool = await self._get_pool()
async with acquire_with_retry(pool) as conn:
# Ensure connection is not in read-only mode (can happen with connection poolers)
await conn.execute("SET SESSION CHARACTERISTICS AS TRANSACTION READ WRITE")
async with conn.transaction():
try:
if fact_type: