From beacb485c415a60ef153c875e4e3345b212014dd Mon Sep 17 00:00:00 2001 From: Gabriel Fior Date: Wed, 4 Dec 2024 15:50:26 -0300 Subject: [PATCH] DB Manager <> db_cache fix attempt (#567) * Reduced pool size | passed connection instead of engine * Added missing commit * Removed comment for deploying --- prediction_market_agent_tooling/tools/db/db_manager.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/prediction_market_agent_tooling/tools/db/db_manager.py b/prediction_market_agent_tooling/tools/db/db_manager.py index f794f0a3..3ef8f1fb 100644 --- a/prediction_market_agent_tooling/tools/db/db_manager.py +++ b/prediction_market_agent_tooling/tools/db/db_manager.py @@ -33,7 +33,7 @@ def __init__(self, api_keys: APIKeys | None = None) -> None: sqlalchemy_db_url.get_secret_value(), json_serializer=json_serializer, json_deserializer=json_deserializer, - pool_size=20, + pool_size=10, pool_recycle=3600, echo=True, ) @@ -52,7 +52,6 @@ def get_connection(self) -> Generator[Connection, None, None]: def create_tables( self, sqlmodel_tables: Sequence[type[SQLModel]] | None = None ) -> None: - # Determine tables to create if sqlmodel_tables is not None: tables_to_create = [] for sqlmodel_table in sqlmodel_tables: @@ -68,7 +67,9 @@ def create_tables( tables_to_create = None # Create tables in the database - SQLModel.metadata.create_all(self._engine, tables=tables_to_create) + with self.get_connection() as connection: + SQLModel.metadata.create_all(connection, tables=tables_to_create) + connection.commit() # Update cache to mark tables as initialized if tables_to_create: