init async resources at app start

modern-python · May 25, 2024 · 0b451c3 · 0b451c3
1 parent 0246594
commit 0b451c3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/app/application.py b/app/application.py
@@ -31,6 +31,7 @@ def __init__(self) -> None:
     @contextlib.asynccontextmanager
     async def lifespan_manager(self, _: fastapi.FastAPI) -> typing.AsyncIterator[dict[str, typing.Any]]:
         try:
+            await ioc.IOCContainer.init_async_resources()
             yield {}
         finally:
             await ioc.IOCContainer.tear_down()

diff --git a/app/db/resource.py b/app/db/resource.py
@@ -10,7 +10,7 @@
 
 
 async def create_sa_engine(settings: Settings) -> typing.AsyncIterator[sa.AsyncEngine]:
-    logger.info("Initializing SQLAlchemy engine")
+    logger.debug("Initializing SQLAlchemy engine")
     engine = sa.create_async_engine(
         url=settings.db_dsn,
         echo=settings.debug,
@@ -19,12 +19,12 @@ async def create_sa_engine(settings: Settings) -> typing.AsyncIterator[sa.AsyncE
         pool_pre_ping=settings.db_pool_pre_ping,
         max_overflow=settings.db_max_overflow,
     )
-    logger.info("SQLAlchemy engine has been initialized")
+    logger.debug("SQLAlchemy engine has been initialized")
     try:
         yield engine
     finally:
         await engine.dispose()
-        logger.info("SQLAlchemy engine has been cleaned up")
+        logger.debug("SQLAlchemy engine has been cleaned up")
 
 
 async def create_session(engine: sa.AsyncEngine) -> typing.AsyncIterator[sa.AsyncSession]: