From c6e10fa192c594079a3979bb4e3ad4a11596fdb6 Mon Sep 17 00:00:00 2001 From: Peter Jung Date: Thu, 5 Dec 2024 14:30:48 +0100 Subject: [PATCH] Try to fix amount of connecitons (#570) --- .../tools/db/db_manager.py | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/prediction_market_agent_tooling/tools/db/db_manager.py b/prediction_market_agent_tooling/tools/db/db_manager.py index 3ef8f1fb..b4a52f89 100644 --- a/prediction_market_agent_tooling/tools/db/db_manager.py +++ b/prediction_market_agent_tooling/tools/db/db_manager.py @@ -28,16 +28,17 @@ def __new__(cls, api_keys: APIKeys | None = None) -> "DBManager": return cls._instances[url_hash] def __init__(self, api_keys: APIKeys | None = None) -> None: + if hasattr(self, "_initialized"): + return sqlalchemy_db_url = (api_keys or APIKeys()).sqlalchemy_db_url self._engine = create_engine( sqlalchemy_db_url.get_secret_value(), json_serializer=json_serializer, json_deserializer=json_deserializer, - pool_size=10, - pool_recycle=3600, - echo=True, + pool_size=2, ) self.cache_table_initialized: dict[str, bool] = {} + self._initialized = True @contextmanager def get_session(self) -> Generator[Session, None, None]: @@ -52,6 +53,7 @@ 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: @@ -67,9 +69,10 @@ def create_tables( tables_to_create = None # Create tables in the database - with self.get_connection() as connection: - SQLModel.metadata.create_all(connection, tables=tables_to_create) - connection.commit() + if tables_to_create is None or len(tables_to_create) > 0: + 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: