Skip to content

Commit 8c315c0

Browse files
committed
Use connection.fetch for asyncpg
1 parent b3669bb commit 8c315c0

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

_python/pgbench_python.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -66,8 +66,7 @@ async def asyncpg_connect(args):
6666

6767

6868
async def asyncpg_execute(conn, query, args):
69-
stmt = await conn.prepare(query)
70-
return len(await stmt.get_list(*args))
69+
return len(await conn.fetch(query, *args))
7170

7271

7372
async def worker(executor, eargs, start, duration, timeout):

0 commit comments

Comments
 (0)