fix: disable asyncpg statement cache for social poolers

app/social/database.py

@@ -71,7 +71,12 @@ class SocialDatabase:
     def __init__(self, settings: Settings) -> None:
         self.settings = settings
         self.database_url = normalize_async_database_url(settings.resolved_social_database_url)
-        self.engine: AsyncEngine = create_async_engine(self.database_url, pool_pre_ping=True)
+        # Supabase/PgBouncer transaction pooling requires asyncpg's prepared
+        # statement cache to be disabled to avoid stale statement-name reuse.
+        connect_args = {"statement_cache_size": 0} if self.database_url.startswith(("postgresql", "postgres")) else {}
+        self.engine: AsyncEngine = create_async_engine(
+            self.database_url, pool_pre_ping=True, connect_args=connect_args
+        )
         if self.database_url.startswith("sqlite"):
             event.listen(self.engine.sync_engine, "connect", self._configure_sqlite)
         self.session_factory = async_sessionmaker(
@@ -81,7 +86,10 @@ class SocialDatabase:
         self.worker_engine: AsyncEngine | None = None
         self.worker_session_factory: async_sessionmaker[AsyncSession] | None = None
         if self.worker_database_url:
-            self.worker_engine = create_async_engine(self.worker_database_url, pool_pre_ping=True)
+            worker_connect_args = {"statement_cache_size": 0} if self.worker_database_url.startswith(("postgresql", "postgres")) else {}
+            self.worker_engine = create_async_engine(
+                self.worker_database_url, pool_pre_ping=True, connect_args=worker_connect_args
+            )
             if self.worker_database_url.startswith("sqlite"):
                 event.listen(self.worker_engine.sync_engine, "connect", self._configure_sqlite)
             self.worker_session_factory = async_sessionmaker(