bugfix: prepared statements don't have .execute()

1 files 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."""