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
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__(
logger = logging.getLogger("psycopg.pool")
-SyncConnectFailedCB: TypeAlias = Callable[["ConnectionPool"], None]
+ConnectFailedCB: TypeAlias = Callable[["ConnectionPool"], None]
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()