From 1b1b0a3697a8bdf62415ceac29c6101aebb0b841 Mon Sep 17 00:00:00 2001 From: Jiang Date: Tue, 24 Feb 2026 17:02:48 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=20row=5Ffactory=20=E5=8F=82?= =?UTF-8?q?=E6=95=B0=E4=BB=A5=E6=94=AF=E6=8C=81=E5=AD=97=E5=85=B8=E8=A1=8C?= =?UTF-8?q?=E8=BF=94=E5=9B=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/infra/db/dynamic_manager.py | 3 +++ 1 file changed, 3 insertions(+) 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