get_redis_server_version() should handle 4 digit version numbers (#1322)

1 files changed, 12 insertions, 4 deletions

diff --git a/rq/utils.py b/rq/utils.py
index 4a22880..fd78ecb 100644
--- a/rq/utils.py
+++ b/rq/utils.py
@@ -14,10 +14,9 @@ import importlib
 import logging
 import numbers
 import sys
-try:
-    from collections.abc import Iterable
-except ImportError:
-    from collections import Iterable
+
+from collections import Iterable
+from distutils.version import StrictVersion
 
 from .compat import as_text, is_python_version, string_types
 from .exceptions import TimeoutFormatError
@@ -248,3 +247,12 @@ def parse_timeout(timeout):
                                          'such as "1h", "23m".')
 
     return timeout
+
+
+def get_version(connection):
+    """
+    Return StrictVersion of Redis server version.
+    This function also correctly handles 4 digit redis server versions.
+    """
+    version_string = connection.info("server")["redis_version"]
+    return StrictVersion('.'.join(version_string.split('.')[:3]))
\ No newline at end of file