from time import sleep, time
from threading import Thread, Event
from collections import Counter
+from typing import Any
import pytest
def test_connection_class(dsn):
- class MyConn(psycopg.Connection):
+ class MyConn(psycopg.Connection[Any]):
pass
with pool.ConnectionPool(dsn, connection_class=MyConn, min_size=1) as p:
import logging
from time import time
from collections import Counter
+from typing import Any
import pytest
async def test_connection_class(dsn):
- class MyConn(psycopg.AsyncConnection):
+ class MyConn(psycopg.AsyncConnection[Any]):
pass
async with pool.AsyncConnectionPool(