From 5aee8f86cab36f0a802f7072f937e13fa5a4fb4d Mon Sep 17 00:00:00 2001 From: schneefux Date: Mon, 6 Mar 2017 20:22:24 +0100 Subject: fixed await error --- worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'worker.py') diff --git a/worker.py b/worker.py index 20f49f6..88ca110 100644 --- a/worker.py +++ b/worker.py @@ -51,7 +51,7 @@ class Worker(object): error = None for jobid, payload, priority in jobs: try: - self._execute_job(jobid, payload, priority) + await self._execute_job(jobid, payload, priority) except JobFailed as err: error = err.args[0] finally: -- cgit v1.3.1