Add logging to pool.wait()

diff --git a/psycopg3/psycopg3/pool/async_pool.py b/psycopg3/psycopg3/pool/async_pool.py
index 4233938b070f635d00ee5959f3ae3530a0fc6b20..dbda524a5c969df048ed5d646b4a1d30342323c1 100644 (file)
--- a/psycopg3/psycopg3/pool/async_pool.py
+++ b/psycopg3/psycopg3/pool/async_pool.py
@@ -91,6 +91,7 @@ class AsyncConnectionPool(BasePool[AsyncConnection]):
                 return
             self._pool_full_event = asyncio.Event()
 
+        logger.info("waiting for pool %r initialization", self.name)
         try:
             await asyncio.wait_for(self._pool_full_event.wait(), timeout)
         except asyncio.TimeoutError:
@@ -103,6 +104,8 @@ class AsyncConnectionPool(BasePool[AsyncConnection]):
             assert self._pool_full_event
             self._pool_full_event = None
 
+        logger.info("pool %r is ready to use", self.name)
+
     @asynccontextmanager
     async def connection(
         self, timeout: Optional[float] = None

diff --git a/psycopg3/psycopg3/pool/pool.py b/psycopg3/psycopg3/pool/pool.py
index 12604846ec53bee638756b2a7dbecefd5cd674fd..a7d6c90ec10fcf8b476f117df332472414362aad 100644 (file)
--- a/psycopg3/psycopg3/pool/pool.py
+++ b/psycopg3/psycopg3/pool/pool.py
@@ -106,6 +106,7 @@ class ConnectionPool(BasePool[Connection]):
                 return
             self._pool_full_event = threading.Event()
 
+        logger.info("waiting for pool %r initialization", self.name)
         if not self._pool_full_event.wait(timeout):
             self.close()  # stop all the threads
             raise PoolTimeout(
@@ -116,6 +117,8 @@ class ConnectionPool(BasePool[Connection]):
             assert self._pool_full_event
             self._pool_full_event = None
 
+        logger.info("pool %r is ready to use", self.name)
+
     @contextmanager
     def connection(
         self, timeout: Optional[float] = None