]> git.ipfire.org Git - thirdparty/psycopg.git/commitdiff
refactor(pool): rename SyncConnectFailedCB to ConnectFailedCB 525/head
authorDaniele Varrazzo <daniele.varrazzo@gmail.com>
Wed, 15 Mar 2023 02:46:54 +0000 (03:46 +0100)
committerDaniele Varrazzo <daniele.varrazzo@gmail.com>
Wed, 15 Mar 2023 02:52:21 +0000 (03:52 +0100)
For every other object in the codebase of which there are sync and
async versions, the sync one doesn't have a prefix.

psycopg_pool/psycopg_pool/null_pool.py
psycopg_pool/psycopg_pool/pool.py

index ca641d7946f533e24fe24c6a73bf5d20ad6d566e..9c796ea71d9e46eec8a3e63cbe4950b2ed3a8859 100644 (file)
@@ -11,7 +11,7 @@ from typing import Any, Callable, Dict, Optional, Tuple, Type
 from psycopg import Connection
 from psycopg.pq import TransactionStatus
 
-from .pool import ConnectionPool, AddConnection, SyncConnectFailedCB
+from .pool import ConnectionPool, AddConnection, ConnectFailedCB
 from .errors import PoolTimeout, TooManyRequests
 from ._compat import ConnectionTimeout
 
@@ -59,7 +59,7 @@ class NullConnectionPool(_BaseNullConnectionPool, ConnectionPool):
         max_lifetime: float = 60 * 60.0,
         max_idle: float = 10 * 60.0,
         reconnect_timeout: float = 5 * 60.0,
-        reconnect_failed: Optional[SyncConnectFailedCB] = None,
+        reconnect_failed: Optional[ConnectFailedCB] = None,
         num_workers: int = 3,
     ):
         super().__init__(
index 19fd2aa285d135f3fb0b15fed1f71a267196b6c7..ad39a5c5602587bcde0b5cdcbd7ee29a6512cc2f 100644 (file)
@@ -27,7 +27,7 @@ from ._compat import Deque
 
 logger = logging.getLogger("psycopg.pool")
 
-SyncConnectFailedCB: TypeAlias = Callable[["ConnectionPool"], None]
+ConnectFailedCB: TypeAlias = Callable[["ConnectionPool"], None]
 
 
 class ConnectionPool(BasePool[Connection[Any]]):
@@ -48,14 +48,14 @@ class ConnectionPool(BasePool[Connection[Any]]):
         max_lifetime: float = 60 * 60.0,
         max_idle: float = 10 * 60.0,
         reconnect_timeout: float = 5 * 60.0,
-        reconnect_failed: Optional[SyncConnectFailedCB] = None,
+        reconnect_failed: Optional[ConnectFailedCB] = None,
         num_workers: int = 3,
     ):
         self.connection_class = connection_class
         self._configure = configure
         self._reset = reset
 
-        self._reconnect_failed: SyncConnectFailedCB
+        self._reconnect_failed: ConnectFailedCB
         self._reconnect_failed = reconnect_failed or (lambda pool: None)
 
         self._lock = threading.RLock()