Use connection.fetch for asyncpg

elprans · elprans · commit 8c315c0cc42b · 2016-07-14T09:39:37.000-04:00
diff --git a/_python/pgbench_python.py b/_python/pgbench_python.py
@@ -66,8 +66,7 @@ async def asyncpg_connect(args):
 
 
 async def asyncpg_execute(conn, query, args):
-    stmt = await conn.prepare(query)
-    return len(await stmt.get_list(*args))
+    return len(await conn.fetch(query, *args))
 
 
 async def worker(executor, eargs, start, duration, timeout):
