From 6197a42598db3233b76c41a1f4fb2b443eb04495 Mon Sep 17 00:00:00 2001 From: schneefux Date: Wed, 8 Mar 2017 18:24:07 +0100 Subject: batch request: forgot to pass priority instead of priorities --- joblib.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'joblib.py') diff --git a/joblib.py b/joblib.py index ba52382..0e0cc41 100644 --- a/joblib.py +++ b/joblib.py @@ -52,12 +52,12 @@ class JobQueue(object): else: priorities = [priority] * len(payloads) ids = [] - for pl in payloads: + for pl, pr in zip(payloads, priorities): ids.append(await con.fetchval(""" INSERT INTO jobs(type, payload, priority) VALUES($1, $2, $3) RETURNING id - """, jobtype, json.dumps(pl), priorities)) + """, jobtype, json.dumps(pl), pr)) if isinstance(payload, list): return ids else: -- cgit v1.3.1