fixed await error

1 files changed, 1 insertions, 1 deletions

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: