From 429b6b8f3a3fc8aa35515395712057d1c7bec13e Mon Sep 17 00:00:00 2001
From: Julius Unverfehrt <julius.unverfehrt@iqser.com>
Date: Tue, 22 Mar 2022 15:41:42 +0100
Subject: [PATCH] change scope for retry consume

---
 src/serve.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/serve.py b/src/serve.py
index 1948abf..7e26ce4 100644
--- a/src/serve.py
+++ b/src/serve.py
@@ -54,11 +54,11 @@ def main():
 
     @retry(ConsumerError, tries=3, delay=5, jitter=(1, 3))
     def consume():
+        consumer = Consumer(visitor, queue_manager)
         try:
-            consumer = Consumer(visitor, queue_manager)
             consumer.consume_and_publish()
         except Exception as err:
-            raise ConsumerError from err
+            raise ConsumerError() from err
 
     try:
         consume()