correct mess in log_redis_info

Author: samuelcolvin

HISTORY.rst

@@ -3,6 +3,10 @@
 History
 -------
 
+v0.10.1 (2017-08-16)
+....................
+* correct format of ``log_redis_info``
+
 v0.10.0 (2017-08-16)
 ....................
 * log redis version when starting worker, fix #64

arq/utils.py

@@ -108,12 +108,10 @@ async def log_redis_info(self, log_func):
         pool = await self.get_redis_pool()
         async with pool.get() as redis:
             info = await redis.info()
-            # from pprint import pprint
-            # pprint(info)
             log_func(
                 f'redis version: {info["server"]["redis_version"]}, '
                 f'mem. usage: {info["memory"]["used_memory_human"]}, '
-                f'clients connected: {info["clients"]["connected_clients"]}, '
+                f'clients connected: {info["clients"]["connected_clients"]}'
             )
 
     async def close(self):

arq/version.py

@@ -2,4 +2,4 @@
 
 __all__ = ['VERSION']
 
-VERSION = StrictVersion('0.10.0')
+VERSION = StrictVersion('0.10.1')

tests/test_utils.py

@@ -75,6 +75,21 @@ async def test_redis_success_log(loop, caplog):
     await pool.wait_closed()
 
 
+async def test_redis_log(loop, caplog):
+    r = RedisMixin(loop=loop)
+
+    log_msgs = []
+
+    def _log(s):
+        log_msgs.append(s)
+
+    await r.log_redis_info(_log)
+    await r.close()
+    print(log_msgs)
+    assert len(log_msgs) == 1
+    assert 'redis version: 3.' in log_msgs[0]
+
+
 @pytest.mark.parametrize('previous,expected,kwargs', [
     (
         datetime(2016, 6, 1, 12, 10, 10),