ashb commented on code in PR #73838:
URL: https://github.com/apache/airflow/pull/73838#discussion_r4154673423
##########
airflow-core/src/airflow/settings.py:
##########
@@ -670,6 +664,16 @@ def dispose_orm(do_log: bool = True):
AsyncSession = None
+async def dispose_async_orm() -> None:
+ """Dispose the async pool on its owning loop after closing its sessions."""
+ global async_engine, AsyncSession
+
+ if async_engine is not None:
+ await async_engine.dispose()
+ async_engine = None
Review Comment:
Addressed in 5005d442626dc46128659f32c3f9c335d2e970c4, and went with
`dispose_async_engine`.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
