ashb commented on code in PR #73838:
URL: https://github.com/apache/airflow/pull/73838#discussion_r4126811604
##########
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:
No, it probably doesn't need it, this is just to parallel the. `dispose_orm`
which sets them to none until a future (re)configure_orm call, so I kept the
same expectation. Let me think
--
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]
