From 34861a5b7284de2b616e0f376dc7fbbbdbb7ea3b Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Thu, 9 Mar 2017 18:58:00 +0100
Subject: do not fail on every batch

---
 worker.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/worker.py b/worker.py
index 2d33537..f6e9e04 100644
--- a/worker.py
+++ b/worker.py
@@ -48,7 +48,7 @@ class Worker(object):
                 continue
 
             await self._windup()
-            critical_error = True
+            critical_error = False
             failed = []
             for jobid, payload, priority in jobs:
                 try:
@@ -60,6 +60,8 @@ class Worker(object):
                         critical_error = err.args[1]
                         if critical_error:
                             break
+                    else:
+                        critical_error = True  # default
             if critical_error:
                 await self._queue.reset([j[0] for j in jobs])
                 logging.warning("batch failed, reset")
-- 
cgit v1.3.1