From 90ee943705e6ed373b778929c0bab94c6e34f674 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Sun, 26 Feb 2017 18:35:32 +0100
Subject: report job fails in queue

---
 api.py | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

(limited to 'api.py')

diff --git a/api.py b/api.py
index 2dfa964..1da9e8d 100644
--- a/api.py
+++ b/api.py
@@ -69,8 +69,12 @@ class Worker(object):
         if jobid is None:
             raise LookupError("no jobs available")
         logging.debug("%s: starting job", jobid)
-        await self._execute_job(jobid, payload, priority)
-        await self._queue.finish(jobid)
+        try:
+            await self._execute_job(jobid, payload, priority)
+            await self._queue.finish(jobid)
+        except crawler.ApiError as error:
+            logging.warning("%s: failed", jobid)
+            await self._queue.fail(jobid, error.args[0])
         logging.debug("%s: finished job", jobid)
 
     async def run(self):
-- 
cgit v1.3.1