From d6f36879af6de9af26a99a9c518152091a1ff1fc Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Tue, 14 Mar 2017 17:43:33 +0100
Subject: acquire: return id not record

---
 joblib.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/joblib.py b/joblib.py
index 7ea908c..04a37d0 100644
--- a/joblib.py
+++ b/joblib.py
@@ -82,7 +82,7 @@ class JobQueue(object):
         ids = []
         async with self._con.transaction():
             for pl, pr in zip(payloads, priorities):
-                ids.append(await insert.fetch(jobtype, pl, pr))
+                ids.append(await insert.fetchval(jobtype, pl, pr))
             await self._con.execute("SELECT pg_notify($1 || '_open', '')",
                                     jobtype)
 
-- 
cgit v1.3.1