Merge pull request #17 from labteral/develop

2.2301.1

Author: brunneis

src/requirements.txt

@@ -1,6 +1,6 @@
-msgpack >= 1.0.2, < 2.0.0
-python-snappy >= 0.5.4, < 1.0.0
+msgpack >= 1.0.4, < 2.0.0
+python-snappy >= 0.6.1, < 1.0.0
 easyrocks >= 2.214.0.1, < 3.0.0
-pyyaml >= 5.4.1, < 6.0.0
-falcon >= 3.0.0, < 4.0.0
-bjoern >= 3.1.0, < 4.0.0
+pyyaml >= 6.0.0, < 7.0.0
+falcon >= 3.1.1, < 4.0.0
+bjoern >= 3.2.2, < 4.0.0

src/setup.py

@@ -26,12 +26,12 @@
       ],
       python_requires='>=3.6',
       install_requires=[
-          'msgpack >= 1.0.2, < 2.0.0',
-          'python-snappy >= 0.5.4, < 1.0.0',
+          'msgpack >= 1.0.4, < 2.0.0',
+          'python-snappy >= 0.6.1, < 1.0.0',
           'easyrocks >= 2.214.0.1, < 3.0.0',
-          'pyyaml >= 5.4.1, < 6.0.0',
-          'falcon >= 3.0.0, < 4.0.0',
-          'bjoern >= 3.1.0, < 4.0.0',
+          'pyyaml >= 6.0.0, < 7.0.0',
+          'falcon >= 3.1.1, < 4.0.0',
+          'bjoern >= 3.2.2, < 4.0.0',
       ],
       entry_points={
           'console_scripts': [

src/stopover_server/broker.py

@@ -44,7 +44,7 @@ class Broker:
 
     def __init__(self, config):
         self.config = config
-        utils.log_dict(self.config, prefix='⚙️ ')
+        utils.log_dict(self.config, prefix='⚙️  ')
 
         self.partitions_by_stream_lock = Lock()
         self.partitions_by_stream = {}
@@ -78,7 +78,7 @@ def check_authorized(self, headers):
     @staticmethod
     def on_get(request, response):
         response.content_type = 'text/html; charset=utf-8'
-        response.body = f'Labteral Stopover {__version__}'
+        response.text = f'Labteral Stopover {__version__}'
 
     def on_post(self, request, response):
         headers = {
@@ -513,7 +513,7 @@ def _prune_loop(self):
 
                     for partition_number in partition_numbers:
                         logging.info(
-                            f'pruning stream {stream} ({partition_number})'
+                            f'pruning stream {stream} (partition {partition_number})'
                         )
 
                         partition = self._get_partition(

src/stopover_server/version.py

@@ -1,4 +1,4 @@
 #!/usr/bin/env python
 # -*- coding: utf-8 -*-
 
-__version__ = '2.2301.0'
+__version__ = '2.2301.1'