From 5d6931c2861a4808c7bc03a28120176a0407b3ef Mon Sep 17 00:00:00 2001
From: Patrick Uiterwijk <puiterwijk@redhat.com>
Date: Jun 02 2016 19:41:15 +0000
Subject: Dont store the decisions if it was requeued


Signed-off-by: Patrick Uiterwijk <puiterwijk@redhat.com>

---

diff --git a/basset-worker b/basset-worker
index c54c546..1368e06 100755
--- a/basset-worker
+++ b/basset-worker
@@ -66,6 +66,7 @@ def callback(ch, method, properties, body):
         log.warning('Arrived at same message. Delaying processing')
         time_module.sleep(1)
 
+    mid = None
     if not run_test and requeued is None:
         mid = core.store_message(action, time, data)
         log.debug('Stored message id: %s' % mid)
@@ -93,8 +94,9 @@ def callback(ch, method, properties, body):
         ch.basic_ack(delivery_tag = method.delivery_tag)
     else:
         log.debug('Storing decisions')
-        mids = core.store_decisions(mid, decisions)
-        log.debug('Decision IDs: %s' % ', '.join(mids))
+        if mid:
+            mids = core.store_decisions(mid, decisions)
+            log.debug('Decision IDs: %s' % ', '.join(mids))
         log.debug('Processing decision')
         if core.process_decisions(decisions) is True:
             log.debug('Decision processed. Acknowledging')