Merge pull request #515 from ydb-platform/custom_loop_for_session_pool

Add an ability to pass custom event loop to QuerySessionPool

Author: vgvoleg

ydb/aio/query/pool.py

@@ -29,6 +29,7 @@ def __init__(
         size: int = 100,
         *,
         query_client_settings: Optional[QueryClientSettings] = None,
+        loop: Optional[asyncio.AbstractEventLoop] = None,
     ):
         """
         :param driver: A driver instance
@@ -42,7 +43,7 @@ def __init__(
         self._queue = asyncio.Queue()
         self._current_size = 0
         self._waiters = 0
-        self._loop = asyncio.get_running_loop()
+        self._loop = asyncio.get_running_loop() if loop is None else loop
         self._query_client_settings = query_client_settings
 
     async def _create_new_session(self):