@@ -576,7 +576,7 @@ async def executemany(self, command: str, args, *, timeout: float=None):
576
576
async with self .acquire () as con :
577
577
return await con .executemany (command , args , timeout = timeout )
578
578
579
- async def fetch (self , query , * args , timeout = None ) -> list :
579
+ async def fetch (self , query , * args , timeout = None , record_class = None ) -> list :
580
580
"""Run a query and return the results as a list of :class:`Record`.
581
581
582
582
Pool performs this operation using one of its connections. Other than
@@ -586,7 +586,7 @@ async def fetch(self, query, *args, timeout=None) -> list:
586
586
.. versionadded:: 0.10.0
587
587
"""
588
588
async with self .acquire () as con :
589
- return await con .fetch (query , * args , timeout = timeout )
589
+ return await con .fetch (query , * args , timeout = timeout , record_class = record_class )
590
590
591
591
async def fetchval (self , query , * args , column = 0 , timeout = None ):
592
592
"""Run a query and return a value in the first row.
@@ -602,7 +602,7 @@ async def fetchval(self, query, *args, column=0, timeout=None):
602
602
return await con .fetchval (
603
603
query , * args , column = column , timeout = timeout )
604
604
605
- async def fetchrow (self , query , * args , timeout = None ):
605
+ async def fetchrow (self , query , * args , timeout = None , record_class = None ):
606
606
"""Run a query and return the first row.
607
607
608
608
Pool performs this operation using one of its connections. Other than
@@ -612,7 +612,7 @@ async def fetchrow(self, query, *args, timeout=None):
612
612
.. versionadded:: 0.10.0
613
613
"""
614
614
async with self .acquire () as con :
615
- return await con .fetchrow (query , * args , timeout = timeout )
615
+ return await con .fetchrow (query , * args , timeout = timeout , record_class = record_class )
616
616
617
617
async def copy_from_table (
618
618
self ,
0 commit comments