don't remove messages from buffer that don't exist

witlox · Jul 3, 2019 · 7ad3d1a · 7ad3d1a
1 parent 88aefda
commit 7ad3d1a
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/dcron/processor.py b/dcron/processor.py
@@ -150,9 +150,12 @@ def clean_buffer(self, uuid):
         """
         self.logger.debug("removing message {0} from buffer".format(uuid))
         g = group(self._buffer)
-        for p in g[uuid]:
-            if p in self._buffer:
-                self._buffer.remove(p)
+        if uuid in g:
+            for p in g[uuid]:
+                if p in self._buffer:
+                    self._buffer.remove(p)
+        else:
+            self.logger.warning("message {0} not in buffer, skipping clean".format(uuid))
 
     async def process(self):
         """

diff --git a/setup.py b/setup.py
@@ -29,7 +29,7 @@
 
 from setuptools import setup
 
-version = "0.9.13"
+version = "0.9.14"
 
 requirements = ['aiohttp',
                 'aiofiles',