Merge pull request #9 from labteral/develop

bugfixes 2.214.1

stopover/broker.py

@@ -255,9 +255,9 @@ def _get_stream_partition_numbers(self, stream: str):
             partition_numbers = []
             self.partitions_by_stream[stream] = partition_numbers
 
-            if 'streams' in self.config and stream in self.config['streams']:
+            try:
                 partitions_target = self.config['streams'][stream]['partitions']
-            else:
+            except KeyError:
                 partitions_target = self.config['global']['partitions']
 
             stream_path = self._get_stream_path(stream)

stopover/partition.py

@@ -129,7 +129,7 @@ def prune(self, ttl: int):
         keys_to_delete = []
 
         with self.lock:
-            for key, value in self._store.scan(prefix='message:'):
+            for key, value in self._store.scan(prefix=Partition.MESSAGE):
 
                 # Backwards compatibility
                 if isinstance(value, bytes):

stopover/stopover.py

@@ -1,7 +1,7 @@
 #!/usr/bin/env python
 # -*- coding: utf-8 -*-
 
-version = '2.214.0'
+version = '2.214.1'
 
 banner = f"""
   ███████████                             ███████████