diff --git a/app/infra/db/dynamic_manager.py b/app/infra/db/dynamic_manager.py index 97064cc..094cbec 100644 --- a/app/infra/db/dynamic_manager.py +++ b/app/infra/db/dynamic_manager.py @@ -6,6 +6,7 @@ from typing import Dict from uuid import UUID from psycopg_pool import AsyncConnectionPool +from psycopg.rows import dict_row from sqlalchemy.engine.url import make_url from sqlalchemy.ext.asyncio import ( AsyncEngine, @@ -103,6 +104,7 @@ class ProjectConnectionManager: min_size=pool_min_size, max_size=pool_max_size, open=False, + kwargs={"row_factory": dict_row}, ) await pool.open() self._ts_cache[key] = pool @@ -134,6 +136,7 @@ class ProjectConnectionManager: min_size=pool_min_size, max_size=pool_max_size, open=False, + kwargs={"row_factory": dict_row}, ) await pool.open() self._pg_raw_cache[key] = pool