def test_cursor_factory(conn):
assert conn.cursor_factory is psycopg.Cursor
- class MyCursor(psycopg.Cursor):
+ class MyCursor(psycopg.Cursor[psycopg.rows.Row]):
pass
conn.cursor_factory = MyCursor
def test_server_cursor_factory(conn):
assert conn.server_cursor_factory is psycopg.ServerCursor
- class MyServerCursor(psycopg.ServerCursor):
+ class MyServerCursor(psycopg.ServerCursor[psycopg.rows.Row]):
pass
conn.server_cursor_factory = MyServerCursor
async def test_cursor_factory(aconn):
assert aconn.cursor_factory is psycopg.AsyncCursor
- class MyCursor(psycopg.AsyncCursor):
+ class MyCursor(psycopg.AsyncCursor[psycopg.rows.Row]):
pass
aconn.cursor_factory = MyCursor
async def test_server_cursor_factory(aconn):
assert aconn.server_cursor_factory is psycopg.AsyncServerCursor
- class MyServerCursor(psycopg.AsyncServerCursor):
+ class MyServerCursor(psycopg.AsyncServerCursor[psycopg.rows.Row]):
pass
aconn.server_cursor_factory = MyServerCursor