From 4820673df0a122cf81c3657aa427045ad9de4818 Mon Sep 17 00:00:00 2001 From: schneefux Date: Fri, 10 Mar 2017 16:22:32 +0100 Subject: bugfix: prepared statements don't have .execute() --- joblib.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/joblib.py b/joblib.py index 7575042..40ba814 100644 --- a/joblib.py +++ b/joblib.py @@ -152,8 +152,8 @@ class JobQueue(object): reasons = reason assert len(jobids) == len(reasons) for jid, rsn in zip(jobids, reasons): - await update.execute(jid, - json.dumps({"error": rsn})) + await update.fetch(jid, + json.dumps({"error": rsn})) async def reset(self, jobid): """Mark a job as open.""" -- cgit v1.3.1