Skip to content

Commit 0b451c3

Browse files
committed
init async resources at app start
1 parent 0246594 commit 0b451c3

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

app/application.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@ def __init__(self) -> None:
3131
@contextlib.asynccontextmanager
3232
async def lifespan_manager(self, _: fastapi.FastAPI) -> typing.AsyncIterator[dict[str, typing.Any]]:
3333
try:
34+
await ioc.IOCContainer.init_async_resources()
3435
yield {}
3536
finally:
3637
await ioc.IOCContainer.tear_down()

app/db/resource.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@
1010

1111

1212
async def create_sa_engine(settings: Settings) -> typing.AsyncIterator[sa.AsyncEngine]:
13-
logger.info("Initializing SQLAlchemy engine")
13+
logger.debug("Initializing SQLAlchemy engine")
1414
engine = sa.create_async_engine(
1515
url=settings.db_dsn,
1616
echo=settings.debug,
@@ -19,12 +19,12 @@ async def create_sa_engine(settings: Settings) -> typing.AsyncIterator[sa.AsyncE
1919
pool_pre_ping=settings.db_pool_pre_ping,
2020
max_overflow=settings.db_max_overflow,
2121
)
22-
logger.info("SQLAlchemy engine has been initialized")
22+
logger.debug("SQLAlchemy engine has been initialized")
2323
try:
2424
yield engine
2525
finally:
2626
await engine.dispose()
27-
logger.info("SQLAlchemy engine has been cleaned up")
27+
logger.debug("SQLAlchemy engine has been cleaned up")
2828

2929

3030
async def create_session(engine: sa.AsyncEngine) -> typing.AsyncIterator[sa.AsyncSession]:

0 commit comments

Comments
 (0)