diff --git a/server/infra/db/pg.py b/server/infra/db/pg.py index 2167e40..190840a 100644 --- a/server/infra/db/pg.py +++ b/server/infra/db/pg.py @@ -18,13 +18,14 @@ class AsyncDB(AbstractDB): str(cnf.db_uri), echo=bool(cnf.app_debug), connect_args=con_arg, - pool_recycle=1800, + pool_recycle=300, + pool_pre_ping=True, ) # self.engine.execution_options(stream_results=True) if self.engine is None: raise ConnectError - session = asyncio.async_sessionmaker(self.engine, expire_on_commit=True) + session = asyncio.async_sessionmaker(self.engine, expire_on_commit=False) if session is None: raise ConnectError self.async_session = session @@ -35,7 +36,7 @@ class AsyncDB(AbstractDB): @property def session(self): - return asyncio.async_sessionmaker(self.engine, expire_on_commit=True) + return asyncio.async_sessionmaker(self.engine, expire_on_commit=False) def session_master(self): return self.async_session()